alphatwirl.concurrently.TaskPackageDropbox

class alphatwirl.concurrently.TaskPackageDropbox(workingArea, dispatcher, sleep=5)

A drop box for task packages.

It puts task packages in a working area and dispatches runners that execute the tasks.

__init__(workingArea, dispatcher, sleep=5)

Methods

__init__(workingArea, dispatcher[, sleep])
close()
open()
put(package)
put_multiple(packages)
receive()
terminate()