# !/usr/bin/env python
# -*- coding:utf-8 -*-
# ref_blog:http://www.open-open.com/home/space-5679-do-blog-id-3247.html
import Queue
import threading
import time
class WorkManager(object):
  def __init__(self, work_num=1000,thread_num=2):
    self.work_queue = Queue.Queue()
    self.threads = []
    self.__init_work_queue(work_num)
    self.__init_thread_pool(thread_num)
  """
    初始化線(xiàn)程
  """
  def __init_thread_pool(self,thread_num):
    for i in range(thread_num):
      self.threads.append(Work(self.work_queue))
  """
    初始化工作隊(duì)列
  """
  def __init_work_queue(self, jobs_num):
    for i in range(jobs_num):
      self.add_job(do_job, i)
  """
    添加一項(xiàng)工作入隊(duì)
  """
  def add_job(self, func, *args):
    self.work_queue.put((func, list(args)))#任務(wù)入隊(duì)，Queue內(nèi)部實(shí)現(xiàn)了同步機(jī)制
  """
    檢查剩余隊(duì)列任務(wù)
  """
  def check_queue(self):
    return self.work_queue.qsize()
  """
    等待所有線(xiàn)程運(yùn)行完畢
  """ 
  def wait_allcomplete(self):
    for item in self.threads:
      if item.isAlive():item.join()
class Work(threading.Thread):
  def __init__(self, work_queue):
    threading.Thread.__init__(self)
    self.work_queue = work_queue
    self.start()
  def run(self):
    #死循環(huán)，從而讓創(chuàng)建的線(xiàn)程在一定條件下關(guān)閉退出
    while True:
      try:
        do, args = self.work_queue.get(block=False)#任務(wù)異步出隊(duì)，Queue內(nèi)部實(shí)現(xiàn)了同步機(jī)制
        do(args)
        self.work_queue.task_done()#通知系統(tǒng)任務(wù)完成
      except Exception,e:
        print str(e)
        break
#具體要做的任務(wù)
def do_job(args):
  print args
  time.sleep(0.1)#模擬處理時(shí)間
  print threading.current_thread(), list(args)
if __name__ == '__main__':
  start = time.time()
  work_manager = WorkManager(10, 2)#或者work_manager = WorkManager(10000, 20)
  work_manager.wait_allcomplete()
  end = time.time()
  print "cost all time: %s" % (end-start)