spawn/pool.py

   1 # pool.py
   2 # 11 Sep 2007
   3
   4 import Queue, thread
   5 q = Queue.Queue()
   6 inited = False
   7
   8 def initialize():
   9     global inited; inited = True
  10     for i in range(50):
  11         thread.start_new_thread(persistent_worker, ())
  12
  13 def persistent_worker():
  14     while True:
  15         computation = q.get()
  16         computation()
  17
  18 def start_new_thread(f, args, kwargs = None):
  19     if not inited: initialize()
  20     if not kwargs: kwargs = {}
  21     q.put(lambda: f(*args, **kwargs))
  22