Python多進程(multiprocessing)共享變量


#!/usr/bin/env python2
# coding: utf8
import multiprocessing

def foo(h,context):
    if h%2 == 0:
        print (h)
    else:
        context.append(h)

if __name__ == "__main__":
    ## 設置共享list
    con = multiprocessing.Manager().list()
    ## 設置進程池大小
    p = multiprocessing.Pool(2)
    for i in range(18):
        # con = multiprocessing.Manager().list()
        p.apply_async(foo,args=(i,con))
    p.close()
    p.join()
    print con


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM