This document is for Celery's development version, which can be significantly different from previous releases. Get old docs here: 2.5.

celery.utils.threads

class celery.utils.threads.Event(verbose=None)

class celery.utils.threads.Thread(group=None, target=None, name=None, args=(), kwargs=None, verbose=None)

class celery.utils.threads.bgThread(name=None, **kwargs)

body()

on_crash(exc_info, msg, *fmt, **kwargs)

run()

stop()

Graceful shutdown.