finger_mainpage.py 文件源码

def manager():

    tasks = mp.cpu_count() - 1
    que = mp.Queue()
    lock = mp.Lock()
    plist = []

    initque(que)    

    for i in xrange(tasks):
        p = mp.Process(target=worker, args=(que, lock, i+1))
        p.start()
        plist.append(p)

    for p in plist:
        p.join()