ตัวอย่างการแตก Thread มารับงานทำเสร็จก็เสร็จกันไปไม่ต้องรอ ง่ายกว่าใช้ Threading แบบปกติ

ThreadPoolExecutor.py

import concurrent.futures
from datetime import datetime
import time
import random


def process(i, data):
  t = random.randrange(5)
  time.sleep(t)
  print("Process index:", i, ' Sleep:', t, ' Current:', datetime.now())


if __name__ == "__main__":

  with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
    for i in range(10):
      executor.submit(process, i, datetime.now())