pyats-async

import time from pyats.async_ import pcall def my_cpu_bound_task(item): """A sample CPU-bound task that simulates work.""" # print(f"Starting task for item {item}...") # Uncomment to see individual task starts time.sleep(1) # Simulate some CPU-intensive work result = item * item # print(f"Finished task for item {item}, result: {result}") # Uncomment to see individual task finishes return result if __name__ == "__main__": items_to_process = [1, 2, 3, 4, 5] print("\n--- Running tasks in parallel with pcall ---") # pcall executes the function in parallel processes and returns results in order. parallel_results = pcall(my_cpu_bound_task, *items_to_process) print(f"All parallel tasks completed. Results: {parallel_results}") print("\n--- Running tasks synchronously for comparison ---") sync_results = [my_cpu_bound_task(item) for item in items_to_process] print(f"All synchronous tasks completed. Results: {sync_results}")