LocalPoolQueue.py 文件源码

def main():
    """
    main process
    """
    m = Manager()
    q = m.Queue()
    plist = []
    pool = Pool(processes=20)
    for proc in plist:
        pool.apply_async(process, (q, proc))
    pool.close()
    pool.join()
    count = 0
    while True:
        if q.empty():
            print "empty"
            break
        else:
            c = q.get()
            print c
            count += c
    print count