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