Free a communication request.

Wait for the worker processes to exit.

Submit a callable to be executed with the given arguments. Schedule the callable to be executed as ``fn(*args, **kwargs)`` and return

Blocking receive.

Clean-up the resources associated with the executor. It is safe to call this method several times. Otherwise, no other methods can be

Nonblocking receive.

Blocking send in standard mode.

Nonblocking send in synchronous mode.

Allocate executor resources eagerly. Args: wait: If ``True`` then bootup will not return until the executor resou

Return the recursion count.

Apply *func* to each element in *iterable*. Equivalent to ``list(map(func, iterable))``. Block until all results are ready and retur

Return the result when it arrives. If *timeout* is not `None` and the result does not arrive within *timeout* seconds then raise `Tim

Acquire mutex, blocking or non-blocking. Args: blocking: If `True`, block until the mutex is held. Returns:

Release mutex.

Return whether the mutex is held.

Broadcast.

Nonblocking send in standard mode.

Blocking test for a matched message.

Blocking send in synchronous mode.

Return ``then(self, on_success, on_failure)``.

Gather to All.

Free counter resources.

Nonblocking test for a matched message.

Return current value and increment. Args: incr: Increment value. Returns: The counter value before increment

Send and receive.

Apply *func* to each argument tuple in *iterable*. Equivalent to ``list(itertools.starmap(func, iterable))``. Block until all result

Test for the completion of all requests.

Scatter.

Wait for all requests to complete.

Like `map()` but return an `iterator`. Equivalent to ``map(func, iterable)``.

Nonblocking test for a matched message.

Gather.

Wake up one or more processes waiting on this condition. Args: n: Maximum number of processes to wake up. Returns: