resonate.processor.processor.Processor

class documentation

class Processor(IProcessor):

Constructor: Processor(workers)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method enqueue Undocumented
Method start Undocumented
Method stop Undocumented
Method _run Undocumented
Instance Variable _sq Undocumented
Instance Variable _threads Undocumented
Instance Variable _workers Undocumented
def __init__(self, workers: int = 4):

Undocumented

def enqueue(self, sqe: SQE[Any]):
overrides resonate.processor.traits.IProcessor.enqueue

Undocumented

def start(self, cmd_queue: CommandQ, pid: str):
overrides resonate.traits.Subsystem.start

Undocumented

def stop(self):
overrides resonate.traits.Subsystem.stop

Undocumented

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

Undocumented

_sq: Queue[SQE[Any]] =

Undocumented

_threads =

Undocumented

_workers =

Undocumented