yyuanoa 2020-08-08 18:39 采纳率: 66.7%
浏览 900
已采纳

为什么python使用线程池会丢失部分数据?

图片说明
图片说明

如题,使用线程池会使结果行数减少,这是为什么?应该怎么修改?
图片说明

改动后还是会出现问题图片说明

  • 写回答

1条回答 默认 最新

  • soar3033 2020-08-08 20:14
    关注
    import os
    from concurrent.futures import ThreadPoolExecutor
    from time import perf_counter
    import time
    import threading as th
    
    lock=th.Lock()
    
    def write(text,path='re.txt'):
        lock.acquire()
        with open(path,'a') as fp:
            fp.write(text)
        lock.release()
    
    def make_test_txt(path='test_txt.txt'):
        with open(path,'w') as fp:
            for i in range(100):
                fp.write(str(i)+'\n')
    
    #os.remove('re.txt')
    
    make_test_txt()
    with open('test_txt.txt') as fp:
        texts=fp.readlines()
    print(len(texts))
    
    t=perf_counter()
    
    pool=ThreadPoolExecutor(max_workers=2)
    pool.map(write,texts)
    pool.shutdown(wait=True)
    
    time.sleep(1)
    with open('re.txt') as fp:
        texts2=fp.readlines()
    print(len(texts2))
    
    
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥20 管道轴向耦合水击问题
  • ¥60 补全networkx TODO部分。
  • ¥15 有内推吗,云计算linux运维方向
  • ¥30 sort cuteSV.vcf by bcftools用IGV可视化出现报错
  • ¥100 SOS!对STK中导出的天体图像进行质心提取有没有人做过啊
  • ¥15 python 欧式距离
  • ¥15 运行qteasy报错
  • ¥15 遗传算法解决有工序顺序约束的大规模FJSP问题
  • ¥15 企业消防水炮塔设计方案
  • ¥20 WORKBENCH网格划分