Updated by Dobrica Pavlinušić on Jun 25 2:52am
Posted by Dobrica Pavlinušić on Jun 24 11:06am
def fun(slp):
def lmbd():
print " start"
time.sleep(slp)
print " end"
return lmbd
def genThread(slip, fun):
tp = ThreadPool(5)
while 1:
tp.request(fun)
time.sleep(slip)
class ThreadPool:
def __init__(self, noft):
self.queue = Queue.Queue()
for i in range(noft):
thread.start_new_thread(self.tfn, ())
def tfn(self):
while 1:
f = self.queue.get()
f()
def request(self, foo):
self.queue.put(foo)
original Sep 15 2:23am
Updated by TamTam Migration on Sep 15 2:23am
Posted by TamTam Migration on Sep 15 2:23am
|
Weblog Navigation
Loading...
|