billiard の API リファレンス
billiard (celery/billiard) の公開 API 48 件 —— クラス 20、関数 8、メソッド 20。実際のソースを静的解析して抽出した正確なシグネチャを掲載しています。
リポジトリ: celery/billiard
| 種別 | 件数 |
|---|---|
| クラス | 20 |
| 関数 | 8 |
| メソッド | 20 |
API 一覧
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
この情報について
掲載しているシグネチャは celery/billiard の公開ソースコードを
Python の ast モジュールで静的解析し、引数名・デフォルト値・
型注釈・戻り値型をそのまま抽出したものです。実装コードは保存していません。
詳しくは仕組みの解説をご覧ください。