resonate.delay_queue.DelayQueue

class documentation

class DelayQueue(Subsystem):

Undocumented

Method	`__init__`	Undocumented
Method	`enqueue`	Undocumented
Method	`start`	Undocumented
Method	`stop`	Undocumented
Method	`_next_release_time`	Undocumented
Method	`_run`	Worker thread that processes the delayed queue.
Instance Variable	`_delayed`	Undocumented
Instance Variable	`_inq`	Undocumented
Instance Variable	`_worker_thread`	Undocumented

def __init__(self): ¶

Undocumented

def enqueue(self, item: Invoke, delay: float): ¶

Undocumented

def start(self, cmd_queue: CommandQ, pid: str): ¶

overrides resonate.traits.Subsystem.start

Undocumented

def stop(self): ¶

overrides resonate.traits.Subsystem.stop

Undocumented

def _next_release_time(self) -> float: ¶

Undocumented

@utils.exit_on_exception
def _run(self, cmd_queue: CommandQ): ¶

Worker thread that processes the delayed queue.

_delayed: list[tuple[float, Invoke]] = ¶

Undocumented

_inq = ¶

Undocumented

_worker_thread: Thread | None = ¶

Undocumented