util.py 文件源码

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