bounded_thread_pool_executor_with_queue_size_limit.py

1import time
2from bounded_pool_executor import BoundedThreadPoolExecutor
3
4def worker(number):
5    print(f"Working on {number}")
6    time.sleep(1)
7    return number * 2
8
9# This executor will have 2 workers and a maximum queue size of 5.
10# If you try to submit more tasks, it will block until a slot is available.
11with BoundedThreadPoolExecutor(max_workers=2, queue_size=5) as executor:
12    for i in range(10):
13        print(f"Submitting {i}")
14        executor.submit(worker, i)