concurrent_futures_example

futures.py

from concurrent.futures import ThreadPoolExecutor, as_completed
import time, random


class Jobs(object):
    # create queue
    queue = ThreadPoolExecutor(max_workers=4)
    jobs = []

    @staticmethod
    def add_job(func, *args):
        Jobs.jobs.append(Jobs.queue.submit(func, *args))

    @staticmethod
    def get_response():
        for item in as_completed(Jobs.jobs):
            print(item.result())



def dummy(num):
    time.sleep(num)
    return True, num