python | 线程池的不断堆积

请看下面的代码。

import time
from concurrent.futures import ThreadPoolExecutor

pool = ThreadPoolExecutor(max_workers=5)


def t(i):
    print(i)
    if i == 5:
        time.sleep(20)
    time.sleep(1)

if __name__ == '__main__':
    while 1:

        tasks = []
        for i in range(10000):
            tasks.append(pool.submit(t, i))

        time.sleep(0.1)
        print("=============")

上面的代码非常不对。

在不断的 while 循环中，会不断的给 tasks 提交任务，旧的任务还没执行结束，新的任务已经提交。

解决的方法有下面几种方法

• wait 关键字
  • python | 线程池阻塞主线程
• 主线程合适的睡眠，以及长时间线程的执行表示
  • python | 线程池与主线程的执行