关于 Python3 ThreadPoolExecutor 的队列大小

【背景】html

    截至 Python 3.6.6,concurrent.futures.ThreadPoolExecutor 中用的都是无·界队列,在生产速度大于消费速度时,可能会耗光系统资源,但愿找到一种方式避免这种状况。python


【方案一】并发

  • 继承 ThreadPoolExecutor,直接修改 _work_queue 为有界队列。ide

  • 优势:简单粗暴直接。工具

  • 缺点:修改了私有属性。线程

  • 示例:https://stackoverflow.com/a/48327162代理


【方案二】code

  • 将任务分组,每组完成后再提交下一组。htm

  • 优势:无需继承,不改变私有属性;能切实有效的避免资源耗费。blog

  • 缺点:组之间的任务是同步的,未充分利用线程,即便有剩余任务也有空闲线程存在。

  • 示例:https://stackoverflow.com/a/49622149


【方案三】


【相关阅读】


*** walker ***

相关文章
相关标签/搜索