fritter.scheduler._PriorityQueueBackedSchedulerImpl

class documentation

class _PriorityQueueBackedSchedulerImpl(Generic[WhenT, WhatT, IDT]): (source)

View In Hierarchy

A Scheduler allows for scheduling work (of the type WhatT, which must be at least a 0-argument None-returning callable) at a given time (WhenT, which much be sortable as a PriorityComparable).

Method callAt Call what at the time when according to the TimeDriver associated with this Scheduler.
Method now Relay now to our TimeDriver.
Instance Variable driver The TimeDriver that this Scheduler will use.
Class Variable _maxWorkBatch Undocumented
Class Variable _newID Undocumented
Class Variable _q Undocumented
def callAt(self, when: WhenT, what: WhatT) -> ScheduledCall[WhenT, WhatT, IDT]: (source)

Call what at the time when according to the TimeDriver associated with this Scheduler.

Returns
ScheduledCall[WhenT, WhatT, IDT]a ScheduledCall that describes the pending call and allows for cancelling it.
def now(self) -> WhenT: (source)

Relay now to our TimeDriver.

driver: TimeDriver[WhenT] = (source)

The TimeDriver that this Scheduler will use.

_maxWorkBatch: int = (source)

Undocumented

_newID: Callable[[], IDT] = (source)

Undocumented

_q: PriorityQueue[ConcreteScheduledCall[WhenT, WhatT, IDT]] = (source)

Undocumented