在if语句检查中休眠线程,Python池

我有一个读取大型文本文件并处理Pools中每一行的代码。


对于elif,我需要将整个过程休眠120秒,换句话说,我希望所有创建的其他Pool都暂停。但是在120秒后,所有的Pool应该恢复工作。


该代码的功能与此类似:


from multiprocessing import Pool

import sys


sys.tracebacklimit = 0


def req(line):


    if "@" not in line:

        # (some function for processing here)

        return line

    elif "somestring" in line:

        #HERE I NEED TO SLEEP ALL POOLS

    else:

        # (some function for processing)

        return line



if __name__ == "__main__":

    pool = Pool(20)

    with open("list.txt") as source_file:

        # chunk the work into batches of 20 lines at a time

        pool.map(req, source_file, 35)


四季花海
浏览 162回答 1
1回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Python