sqlite_addvalidfiled_update.py 文件源码

def manager(dbs, urldict):

    cpus = mp.cpu_count()
    que = mp.Queue()
    for db in dbs:
        que.put(db)

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

    for p in plist:
        p.join()