billiard API reference
48 public APIs from billiard (celery/billiard) — 20 classes, 8 functions, 20 methods. Signatures extracted by static analysis of the actual source.
Repository: celery/billiard
| Kind | Count |
|---|---|
| Classes | 20 |
| Functions | 8 |
| Methods | 20 |
API list
func
billiard._win.kill_processtree(pid, signum)Kill a process and all its descendants
class
billiard.connection.ListenerReturns a listener object.
class
billiard.connection.PipeConnectionConnection class based on a Windows named pipe.
class
billiard.connection.PipeListenerRepresentation of a named pipe
method
billiard.context.BaseContext.Barrier(parties, action=None, timeout=None)Returns a barrier object
method
billiard.context.BaseContext.BoundedSemaphore(value=1)Returns a bounded semaphore object
method
billiard.context.BaseContext.Condition(lock=None)Returns a condition object
method
billiard.context.BaseContext.Event()Returns an event object
method
billiard.context.BaseContext.JoinableQueue(maxsize=0)Returns a queue object
method
billiard.context.BaseContext.Lock()Returns a non-recursive lock object
method
billiard.context.BaseContext.Queue(maxsize=0)Returns a queue object
method
billiard.context.BaseContext.RLock()Returns a recursive lock object
method
billiard.context.BaseContext.RawArray(typecode_or_type, size_or_initializer)Returns a shared array
method
billiard.context.BaseContext.RawValue(typecode_or_type, *args)Returns a shared object
method
billiard.context.BaseContext.Semaphore(value=1)Returns a semaphore object
method
billiard.context.BaseContext.SimpleQueue()Returns a queue object
class
billiard.einfo.ExceptionInfoException wrapping an exception and its traceback.
class
billiard.exceptions.RestartFreqExceededRestarts too fast.
class
billiard.exceptions.SoftTimeLimitExceededThe soft time limit has been exceeded.
class
billiard.exceptions.WorkerLostErrorThe worker processing a job has exited prematurely.
func
billiard.forkserver.main(listener_fd, alive_r, preload, main_path=None, sys_path=None)Run forkserver.
class
billiard.managers.BaseManagerBase class for managers
class
billiard.managers.BaseProxyA base for proxies of shared objects
method
billiard.managers.Server.handle_request(c)Handle a new connection
method
billiard.managers.Server.number_of_objects(c)Number of shared objects
method
billiard.managers.Server.serve_forever()Run the server forever
method
billiard.managers.Server.shutdown(c)Shutdown this process
class
billiard.managers.TokenType to uniquely identify a shared object
method
billiard.pool.Pool.apply(func, args=(), kwds={})Equivalent of `func(*args, **kwargs)`.
class
billiard.pool.WorkersJoinedAll workers have terminated.
class
billiard.popen_spawn_win32.PopenStart a subprocess to run the code of a process object
class
billiard.queues.QueueQueue type using a pipe, buffer and thread
func
billiard.reduction.DupFd(fd)Return a wrapper for an fd.
class
billiard.reduction.DupHandlePicklable wrapper for a handle.
method
billiard.reduction.DupHandle.detach()Get the handle.
class
billiard.reduction.ForkingPicklerPickler subclass used by multiprocessing.
func
billiard.reduction.dump(obj, file, protocol=None)Replacement for pickle.dump() using ForkingPickler.
func
billiard.reduction.duplicate(handle, target_process=None, inheritable=False)Duplicate a handle.
func
billiard.reduction.recv_handle(conn)Receive a handle over a local connection.
class
billiard.resource_sharer.DupFdWrapper for fd which can be used at any time.
method
billiard.resource_sharer.DupFd.detach()Get the fd.
class
billiard.resource_sharer.DupSocketPicklable wrapper for a socket.
method
billiard.resource_sharer.DupSocket.detach()Get the socket.
func
billiard.semaphore_tracker.main(fd)Run semaphore tracker.
class
billiard.synchronize.ConditionCondition variable
class
billiard.synchronize.LockNon-recursive lock.
class
billiard.synchronize.RLockRecursive lock
func
billiard.util.get_logger()Returns logger used by multiprocessing
About this data
These signatures were extracted from the public source of celery/billiard
using Python's ast module. Argument names, default values,
type annotations and return types are taken verbatim from the code.
Implementation bodies are never stored. See
how it works for details.