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 a package.
put_multiple(packages)	Put multiple packages.
receive()	Return pairs of package indices and results.
terminate()