你好,我想使用multiprocessing对一个文件进行操作,但是没有达到预期效果..代码如下,传入文件流后,子进程并没有运行,连打印输出都没有,请问如何解决?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贡献1802条经验 获得超5个赞
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()
添加回答
举报
0/150
提交
取消