Changeset View

Standalone View

Show First 20 Lines • Show All 467 Lines • ▼ Show 20 Lines	def handle_test_cases():
job_queue.task_done()		job_queue.task_done()

##		##
# Setup our threads, and start sending tasks		# Setup our threads, and start sending tasks
##		##

# Start our result collection thread.		# Start our result collection thread.
t = threading.Thread(target=handle_update_messages)		t = threading.Thread(target=handle_update_messages)
t.setDaemon(True)		t.daemon = True
t.start()		t.start()

# Start some worker threads		# Start some worker threads
for j in range(num_jobs):		for j in range(num_jobs):
t = threading.Thread(target=handle_test_cases)		t = threading.Thread(target=handle_test_cases)
t.setDaemon(True)		t.daemon = True
t.start()		t.start()

# Push all our test cases into the job queue.		# Push all our test cases into the job queue.
for i, t in enumerate(test_list):		for i, t in enumerate(test_list):
job_queue.put(TestCase(i, t, tests_dir, tmpdir, flags))		job_queue.put(TestCase(i, t, tests_dir, tmpdir, flags))

# Wait for all the jobs to be completed		# Wait for all the jobs to be completed
job_queue.join()		job_queue.join()
▲ Show 20 Lines • Show All 286 Lines • Show Last 20 Lines