Skip to main content

Worker

Pool worker process.

Attributes

AttributeTypeDescription
outqmultiprocessing.QueueThe output queue used to send control messages, such as the WORKER_UP signal, back to the parent process.

Constructor

Signature

def Worker()

Methods


on_loop_start()

@classmethod
def on_loop_start(
pid: int
)

Sends a WORKER_UP message when the process is ready to accept work, which notifies the parent that the input queue file descriptor is writable.

Parameters

NameTypeDescription
pidintThe process identifier of the worker process being started