multiprocessing.pool.Pool.apply()

apply(func[, args[, kwds]]) Call func with arguments args and keyword arguments kwds. It blocks until the result is ready. Given this blocks, apply_async() is better suited for performing work in parallel. Additionally, func is only executed in one of the workers of the pool.

multiprocessing.pool.Pool

class multiprocessing.pool.Pool([processes[, initializer[, initargs[, maxtasksperchild[, context]]]]]) A process pool object which controls a pool of worker processes to which jobs can be submitted. It supports asynchronous results with timeouts and callbacks and has a parallel map implementation. processes is the number of worker processes to use. If processes is None then the number returned by os.cpu_count() is used. If initializer is not None then each worker process will call initialize

multiprocessing.pool.AsyncResult.wait()

wait([timeout]) Wait until the result is available or until timeout seconds pass.

multiprocessing.pool.AsyncResult.successful()

successful() Return whether the call completed without raising an exception. Will raise AssertionError if the result is not ready.

multiprocessing.pool.AsyncResult.ready()

ready() Return whether the call has completed.

multiprocessing.pool.AsyncResult.get()

get([timeout]) Return the result when it arrives. If timeout is not None and the result does not arrive within timeout seconds then multiprocessing.TimeoutError is raised. If the remote call raised an exception then that exception will be reraised by get().

multiprocessing.pool.AsyncResult

class multiprocessing.pool.AsyncResult The class of the result returned by Pool.apply_async() and Pool.map_async(). get([timeout]) Return the result when it arrives. If timeout is not None and the result does not arrive within timeout seconds then multiprocessing.TimeoutError is raised. If the remote call raised an exception then that exception will be reraised by get(). wait([timeout]) Wait until the result is available or until timeout seconds pass. ready() Return whether th

multiprocessing.Pipe()

multiprocessing.Pipe([duplex]) Returns a pair (conn1, conn2) of Connection objects representing the ends of a pipe. If duplex is True (the default) then the pipe is bidirectional. If duplex is False then the pipe is unidirectional: conn1 can only be used for receiving messages and conn2 can only be used for sending messages.

multiprocessing.managers.SyncManager.Value()

Value(typecode, value) Create an object with a writable value attribute and return a proxy for it.

multiprocessing.managers.SyncManager.Semaphore()

Semaphore([value]) Create a shared threading.Semaphore object and return a proxy for it.