How can I set timeouts for tasks in concurrent futures?

How can I set timeouts for tasks in concurrent futures?

You can set timeouts for tasks in concurrent futures using the timeout parameter in the Future.result() method.

Can you show me a code example?

Sure! Here's a simple example:

from concurrent.futures import ThreadPoolExecutor, as_completed
import time

def task(n):
    time.sleep(n)
    return n

with ThreadPoolExecutor() as executor:
    futures = {executor.submit(task, i): i for i in range(5)}
    for future in as_completed(futures, timeout=3):
        try:
            result = future.result(timeout=2)
            print(f'Task completed with result: {result}')
        except Exception as e:
            print(f'Task generated an exception: {e}')

What happens if a task exceeds the timeout?

If a task exceeds the timeout, a concurrent.futures.TimeoutError will be raised, which you can catch and handle.

Are there any best practices for using timeouts?

Yes, it's best to set reasonable timeouts based on expected task durations and to handle exceptions gracefully.