threading_example.py

#!/usr/bin/python
import threading
import Queue

class Runner(threading.Thread):
	def __init__(self, queue):
		threading.Thread.__init__(self)
		self.queue = queue

	def run(self):
		while True:
			job = self.queue.get()
			# do shit
			self.queue.task_done()

if __name__ == "__main__":	
	queue = Queue.Queue()
	for i in range(10):
		thread = Runner(queue)
		thread.setDaemon(True)
		thread.start()

	# Do this lots of times in one thread
	queue.put({})

	# DO this on exit - stops all the threads
	queue.join()