在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Python/ 請問關于apply_async對文件操作的問題

請問關于apply_async對文件操作的問題

你好，我想使用multiprocessing對一個文件進行操作，但是沒有達到預期效果..代碼如下,傳入文件流后,子進程并沒有運行,連打印輸出都沒有,請問如何解決?

from multiprocessing.pool import Pool


def filetest(ff):
    print("f!")
    print(ff.name)
    print(ff.read(20))
    print("ff!")


if __name__ == '__main__':
    p = Pool(2)
    f = r'C:\Users\77395\Downloads\1.ts'
    ff = open(f, 'rb')
    for i in range(0,5):
        p.apply_async(filetest, args=(ff,))
    p.close()
    p.join()
回答
編輯回答
掛念你

file object 不能被pickle

from multiprocessing.pool import Pool


def filetest(content):
    print content

if __name__ == '__main__':
    p = Pool(2)
    f = r'./1.txt'
    ff = open(f, 'rb')
    p.map_async(filetest, ff)
    p.close()
    p.join()
2018年2月1日 21:15