lesson07_fib_parallel.py

# SuperFastPython.com
# calculate some large fibonacci numbers in parallel
from concurrent.futures import ProcessPoolExecutor

# calculate the nth fibonacci number
def fibonacci(n):
 # start the sequence
 f0, f1 = 0, 1
 # compute the nth number
 for _ in range(0, n):
 f0, f1 = f1, (f1 + f0)
 return f0

# protect the entry point
if __name__ == '__main__':
 # create the process pool
 with ProcessPoolExecutor() as exe:
 # fibonacci numbers to calculate
 numbers = range(10000)
 # calculate concurrently
 fibs = exe.map(fibonacci, numbers)
 # store results
 results = dict(zip(numbers, fibs))
 print('Done')