import threadpool
pool = threadpool.ThreadPool(10)
def fun(s):
print(s)
while 1:
params = create_num()
requests = threadpool.makeRequests(fun, params)
[pool.putRequest(req) for req in requests]
pool.wait()
import threadpool
pool = threadpool.ThreadPool(10)
def fun(s):
print(s)
while 1:
params = create_num()
requests = threadpool.makeRequests(fun, params)
[pool.putRequest(req) for req in requests]
pool.wait()