resonate.processor.Processor

class documentation

class Processor:

Constructor: Processor(workers)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method enqueue Undocumented
Method start Undocumented
Method stop Undocumented
Instance Variable sq Undocumented
Instance Variable threads Undocumented
Method _run Undocumented
def __init__(self, workers: int | None = None):

Undocumented

def enqueue(self, func: Callable[[], Any], callback: Callable[[Result[Any]], None]):

Undocumented

def start(self):

Undocumented

def stop(self):

Undocumented

sq =

Undocumented

threads =

Undocumented

def _run(self):

Undocumented