我编写了以下概念验证代码：
import time
from multiprocessing.pool import ThreadPool
class Maybe:
def __init__(self):
self._value = None
self._exists = False
def exists(self):
return self._exists
def value(self):
if not self.exists():
raise ValueError("Maybe doesn't hold any value")
return self._value
def set(self, value):
self._value = value
self._exists = True
def unset(self):
self._value = None
self._exists = False
class Future(object):
def __init__(self):
self._holder = Maybe()
self._handler = None
def _set(self, value):
self._holder.set(value)
self._invoke()
def _invoke(self):
if self._handler and self._holder.exists():
self._handler(self._holder.value())
def then(self, handler):
self._handler = handler
self._invoke()
def fib(count):
f,s = 0,1
for i in xrange(count):
f,s =s,f+s
return s
pool = ThreadPool(5)
def test(fun, arg):
def print_fib(x):
print("fib => {0}, {1}\n".format(arg, len(str(x))))
tb = time.time()
future = Future()
future.then(print_fib)
future._async_result = pool.apply_async(fun, [arg], callback=future._set)
ta = time.time()
print ("Time elapsed : {0}".format(ta - tb))
return future
x1=test(fib, 2029)
x2=test(fib, 989999)
x3=test(fib, 103)
x4=test(fib, 38484)
x5=test(fib, 20)
time.sleep(3)
我希望所有的调用都能异步运行。但是它们似乎并不异步运行。例如，带103参数的调用应该在带参数的调用之前完成989999。我看不到这种情况。如果我对第二个调用使用更大的参数，则即使是第一个调用也要花费更多时间。
有人可以解释发生了什么吗？为什么它们不异步运行？
问题是ThreadPool将所有线程设置为守护程序，即，如果主线程退出，则所有线程将被终止。time.sleep(3)这不足以使您的流程完成其任务，这就是原因。请注意，您的“经过时间”日志不正确，因为它测量的是触发线程所需的时间，而不是实际任务。
您应该始终.join线程化。通过ThreadPool以下代码，您可以做到这一点：
...
x1=test(fib, 2029)
x2=test(fib, 989999)
x3=test(fib, 103)
x4=test(fib, 38484)
x5=test(fib, 20)
pool.close()
pool.join()
同时将所有日志移到print_fib功能上，它应能按预期工作。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句