#!/usr/bin/env python
#encoding:utf-8

import Queue, threading, time, random

NUM_WORKERS = 3
thread_pool = []

class MyThread(threading.Thread):
	def __init__(self, queue, thread_no, processer):
		self.queue = queue
		self.thread_no = thread_no
		self.processer = processer
		threading.Thread.__init__(self, name = thread_no)

	def run(self):
		while self.queue.qsize() > 0:
			self.processer(self.queue.get(), self.thread_no)

def doTask(task, thread_no):
	time.sleep(random.random() * 3)
	print "doing", task, "thread_no", thread_no 

if __name__ == "__main__":
	print "begin..."
	q = Queue.Queue(0)

	map(lambda x : q.put(x), range(NUM_WORKERS * 2))
	print "job qsize:", q.qsize()
	map(lambda x : thread_pool.append(MyThread(q, x, doTask)), range(NUM_WORKERS))
	map(lambda x : x.setDaemon(True), thread_pool)
	map(lambda x : x.start(), thread_pool)
	map(lambda x : x.join(), thread_pool)
		
	print "done"