Worker
Pool worker process.
Attributes
| Attribute | Type | Description |
|---|---|---|
| outq | multiprocessing.Queue | The 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
| Name | Type | Description |
|---|---|---|
| pid | int | The process identifier of the worker process being started |