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

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

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

倚天杖 2018-09-23 20:19:02
你好,我想使用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 回答

?
一只名叫tom的猫

TA贡献1906条经验 获得超3个赞

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-23
  • 1 回答
  • 0 关注
  • 683 浏览
慕课专栏
更多

添加回答

举报

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