ppft_parallel_job_server_submit_and_retrieve_results.py

1import ppft
2
3# Create a job server
4job_server = ppft.Server()
5
6# Define a simple function to be executed in parallel
7def sum_sequence(n):
8    """Calculates the sum of first n integers"""
9    return sum(range(1, n + 1))
10
11# Submit jobs to the server
12# The submit method takes: (function, arguments, dependencies, modules)
13job1 = job_server.submit(sum_sequence, (100,))
14job2 = job_server.submit(sum_sequence, (1000,))
15
16# Retrieve and print the results
17print("Result of job 1:", job1())
18print("Result of job 2:", job2())
19
20# Print execution statistics
21job_server.print_stats()