pathos_processpool_parallel_map_quickstart.py

1from pathos.pools import ProcessPool
2
3# A simple function to be executed in parallel
4def power(x, y):
5    return x**y
6
7# Create a pool of workers (defaults to the number of CPUs available)
8pool = ProcessPool()
9
10# Define some data
11x_values = [1, 2, 3, 4]
12y_values = [5, 6, 7, 8]
13
14# Perform a parallel map
15results = pool.map(power, x_values, y_values)
16
17print(results)
18# Expected Output: [1, 64, 2187, 65536]