async multiprocessing tutorial

import time
from itertools import zip_longest

import random
from multiprocessing import Process


def f(inflow_cache):
    time.sleep(random.randint(2, 5))
    inflow_cache = list(filter(lambda t: t is not None, inflow_cache))

    print('average sum', sum(inflow_cache, 0.) / len(inflow_cache))


def get_flow():
    init_state = [random.randint(1, random.randint(1, 10)) for _ in range(random.randint(1, 10))]
    for record in init_state:
        yield record

    for _ in range(random.randint(10, 20)):
        yield random.randint(1, random.randint(1, 10))


def grouper(iterable, n, fillvalue=None):
    args = [iter(iterable)] * n
    return zip_longest(fillvalue=fillvalue, *args)


if __name__ == '__main__':
    processes = []
    for chunk in grouper(get_flow(), 5):
        p = Process(target=f, args=(chunk,))
        p.start()
        processes.append(p)

    [p.join() for p in processes]
    print('That\'s all, folks!')