Module jumpscale.tools.poolexecutor

Expand source code
from .poolexecutor import PoolExecutor

"""

def sleepf(howlong, name="fun"):
    print("{} is sleeping for {}".format(name, howlong))
    for i in range(howlong):
        print("{} is sleeping slept for {}".format(name, howlong - i))
        gevent.sleep(i)

with j.tools.poolexecutor.PoolExecutor() as p:
    for i in range(5):
        p.task_add(sleepf, i, name="fun{}".format(i))

    gs = p.run()
    print(p.results(gs))


"""

Sub-modules

jumpscale.tools.poolexecutor.poolexecutor