How can I use concurrent futures in Python?

How can I use concurrent futures in Python?

You can use the concurrent.futures module to run tasks concurrently using threads or processes. Would you like an example?

Yes, please provide an example of using ThreadPoolExecutor.

Sure! Here's a simple example:

from concurrent.futures import ThreadPoolExecutor
import time

def task(n):
    time.sleep(n)
    return f'Task {n} completed'

with ThreadPoolExecutor(max_workers=3) as executor:
    futures = [executor.submit(task, i) for i in range(5)]
    for future in futures:
        print(future.result())

This will run tasks concurrently with a maximum of 3 threads.

What if I want to use ProcessPoolExecutor instead?

You can simply replace ThreadPoolExecutor with ProcessPoolExecutor. Here's how:

from concurrent.futures import ProcessPoolExecutor

# The rest of the code remains the same

This is useful for CPU-bound tasks.