你好，我想使用multiprocessing對一個(gè)文件進(jìn)行操作，但是沒有達(dá)到預(yù)期效果..代碼如下,傳入文件流后,子進(jìn)程并沒有運(yùn)行,連打印輸出都沒有,請問如何解決?from multiprocessing.pool import Pooldef 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()
1 回答
12345678_0001
TA貢獻(xiàn)1802條經(jīng)驗(yàn) 獲得超5個(gè)贊
file object 不能被pickle
from multiprocessing.pool import Pooldef filetest(content): print contentif __name__ == '__main__': p = Pool(2) f = r'./1.txt' ff = open(f, 'rb') p.map_async(filetest, ff) p.close() p.join()
添加回答
舉報(bào)
0/150
提交
取消