Changeset View

Standalone View

Show First 20 Lines • Show All 466 Lines • ▼ Show 20 Lines	def handle_test_cases():
update_queue.put(result)		update_queue.put(result)
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)		resultCollector = threading.Thread(target=handle_update_messages)
t.daemon = True		resultCollector.daemon = True
t.start()		resultCollector.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.daemon = 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.
▲ Show 20 Lines • Show All 291 Lines • Show Last 20 Lines