python 多线程笔记

    while True:
        line = fileInfo.readline()
        if line:
            threadPool.submit(task,line,q,noFile,okFile)
        else:
            threadPool.shutdown()
            isStop = True
            noFile.close()
            okFile.close()
            fileInfo.close()
            break

如上代码,线程池提交任务,默认读到的line为空时退出while循环,此时主线程终止,程序退出,调用shutDown()方法等待线程池中的任务执行完再退出程序,shutDown源码如下,默认等待,可以设置为不等待

    def shutdown(self, wait=True):
        with self._shutdown_lock:
            self._shutdown = True
            self._work_queue.put(None)
        if wait:
            for t in self._threads:
                t.join(sys.maxint)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容