celery.concurrency.base

Базовый пул выполнения.

classcelery.concurrency.base.BasePool(limit=None, putlocks=True, forking_enable=True, callbacks_propagate=(), app=None, **options)

Пул задач.

CLOSE=2

RUN=1

TERMINATE=3

classTimer(schedule:Timer|None=None, on_error:Callable[[Exception],None]|None=None, on_tick:Callable[[float],None]|None=None, on_start:Callable[[Timer],None]|None=None, max_interval:float|None=None, **kwargs:Any)

Поток таймера.

Примечание

Используется только для транспортов, не поддерживающих AsyncIO.

classEntry(fun, args=None, kwargs=None)

Элемент расписания.

args

cancel()

canceled

propertycancelled

fun

kwargs

tref

Schedule

псевдоним Timer

call_after(*args:Any, **kwargs:Any) → Entry

call_at(*args:Any, **kwargs:Any) → Entry

call_repeatedly(*args:Any, **kwargs:Any) → Entry

cancel(tref:Entry) → None

clear() → None

empty() → bool

ensure_started() → None

enter(entry:Entry, eta:float, priority:int|None=None) → Entry

enter_after(*args:Any, **kwargs:Any) → Entry

exit_after(secs:float, priority:int=10) → None

next() → float|None

on_tick:Callable[[float],None]|None=None

propertyqueue:list

run() → None

Метод, описывающий работу потока.

Этот метод можно переопределить в подклассе. Стандартный метод run() вызывает вызываемый объект, переданный конструктору объекта в качестве аргумента target (если он задан), используя позиционные и именованные аргументы, полученные соответственно из аргументов args и kwargs.

running:bool=False

stop() → None

propertyactive

apply_async(target, args=None, kwargs=None, **options)

Эквивалент встроенной функции apply().

Желательно, чтобы обратные вызовы возвращали управление как можно скорее, иначе поток, обрабатывающий результат, будет заблокирован.

body_can_be_buffer=False

close()

did_start_ok()

flush()

propertyinfo

is_green=False

установлено в значение true, если пул использует greenlet.

maintain_pool(*args, **kwargs)

propertynum_processes

on_apply(*args, **kwargs)

on_close()

on_hard_timeout(job)

on_soft_timeout(job)

on_start()

on_stop()

on_terminate()

register_with_event_loop(loop)

restart()

signal_safe=True

установлено в значение true, если пул можно завершить из обработчика сигнала.

start()

stop()

task_join_will_block=True

terminate()

terminate_job(pid, signal=None)

uses_semaphore=False

используется только пулом multiprocessing

celery.concurrency.base.apply_target(target, args=(), kwargs=None, callback=None, accept_callback=None, pid=None, getpid=<built-in function getpid>, propagate=(), monotonic=<built-in function monotonic>, **_)

Применяет функцию в контексте пула.