celery.worker.pidbox consumer = None on_message(body, message)[源代码] on_stop() shutdown(c)[源代码] start(c) class celery.worker.pidbox.gPidbox(c)[源代码] on_stop() start(c)[源代码]