def __init__(self, n_consumers, initializer = None, initargs = ()):
self._tasks = mp.JoinableQueue()
self._ntasks = 0
self._results = mp.Queue()
self._state = "OPEN"
self._done = False
self._consumers = [ ConnectedConsumer(self._tasks, self._results,
initializer = initializer, initargs = initargs) \
for i in xrange(n_consumers) ]
for consumer in self._consumers:
consumer.daemon = True
评论列表
文章目录