test_multiprocess.py 文件源码

def manager():

    cpus = mp.cpu_count()
    que = mp.Queue()

    lock = mp.Lock()
    plist = []
    for i in xrange(cpus-1):
        p = mp.Process(target=worker, args=(que, lock, i+1))
        p.start()
        plist.append(p)

    for p in plist:
        p.join()     

    ret=set()
    while que.qsize() > 0:

            item = que.get()
            ret.add(item)
    print ret