gPidbox

Worker pidbox (greenlet).

Constructor

Signature

def gPidbox() - > null

---

Methods

---

start()

@classmethod
def start(
    c: celery.worker.consumer.Consumer
)

Spawns the pidbox event loop as a non-blocking greenlet within the worker's pool.

Parameters

Name	Type	Description
c	celery.worker.consumer.Consumer	The consumer instance providing the execution pool and connection context

---

on_stop()

@classmethod
def on_stop()

Signals the pidbox loop to shut down and blocks until the broadcast thread has successfully terminated.

---

reset()

@classmethod
def reset()

Increments the internal reset counter to trigger a re-initialization of the consumer channel in the next loop iteration.

---

loop()

@classmethod
def loop(
    c: celery.worker.consumer.Consumer
)

Runs the main event loop that drains events from the broker and handles periodic resets or shutdown signals.

Parameters

Name	Type	Description
c	celery.worker.consumer.Consumer	The consumer instance providing the connection for reading events

---