python: run_together

run_together.py

def run_together(*tasks) -> Tuple:
    from multiprocessing.pool import ThreadPool
    pool = ThreadPool(len(tasks) if len(tasks) < 8 else 8)
    results = []
    for task in tasks:
        if len(task) > 3:
            raise ValueError('Syntax Error')
        if len(task) > 1:
            a = task[1] if isinstance(task[1], tuple) else (task[1],)
        else:
            a = tuple()
        k = task[2] if len(task) == 3 else {}
        results.append(pool.apply_async(task[0], args=a, kwds=k))
    pool.close()
    pool.join()
    results = [r.get() for r in results]
    return tuple(results)


if __name__ == '__main__':
    def fprint(b, c=None):
        return str(b) + ' ' + str(c) + ' ' + str(time.time())

    t = run_together(
        (fprint, '1', {'c': 'a'}),
        (fprint, 2, {'c': 'b'}),
        (fprint, '3', {'c': 'c'}),
        (fprint, 4, {'c': 'd'})
    )
    print(type(t), t)
    try:
        t = run_together(
            (1, 2, 3, 4)
        )
    except ValueError as e:
        print(e)