koi_net.components.interfaces.threaded_component

Classes

ThreadedComponent(log, logging_context, ...)

Base class for threaded component.

class koi_net.components.interfaces.threaded_component.ThreadedComponent(log, logging_context, shutdown_signal, exception_queue)

Bases: object

Base class for threaded component. Derived classes MUST set self.root_dir.

Parameters:

• log (Logger)

• logging_context (LoggingContext)

• shutdown_signal (Event)

• exception_queue (Queue[Exception])

exception_queue: Queue[Exception]

log: Logger

logging_context: LoggingContext

run()

Processing loop for thread.

shutdown_signal: Event

start()

stop()

thread: Thread | None = None