为了账号安全,请及时绑定邮箱和手机立即绑定

请问关于apply_async对文件操作的问题

请问关于apply_async对文件操作的问题

一只萌萌小番薯 2018-09-10 12:07:49
你好,我想使用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()


查看完整回答
反对 回复 2018-09-10
  • 1 回答
  • 0 关注
  • 1374 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信