billiard_process_pool_sync_and_async_task_quickstart.py

1from billiard import Pool
2
3def square(n):
4    return n * n
5
6if __name__ == '__main__':
7    # Create a pool of 4 worker processes
8    with Pool(processes=4) as pool:
9        # Perform a synchronous map
10        result = pool.map(square, range(10))
11        print(f"Synchronous map result: {result}")
12
13        # Perform an asynchronous task
14        res = pool.apply_async(square, (10,))
15        print(f"Asynchronous apply result: {res.get(timeout=1)}")