gistfile1.txt

from collections import deque

results = deque(pool.apply_async(...) for job in jobs)

while results:
  current = results.popleft()
  
  try:
    current_result = current.get(0.1)
    process(current_result)
  except multiprocessing.TimeoutError:
    results.append(current)