import time from concurrent import futures def sleep(delay): time.sleep(delay) return delay def test(): executor = futures.ProcessPoolExecutor() fs = [executor.submit(sleep, delay) for delay in [2, 1, 0]] assert [future.result() for future in futures.as_completed(fs)] == [0, 1, 2]