ThreadScheduler

a scheduler of threads, of course!

class DIRAC.Core.Utilities.ThreadScheduler.ThreadScheduler(enableReactorThread=True, minPeriod=60)

Bases: object

__init__(enableReactorThread=True, minPeriod=60)
addPeriodicTask(period, taskFunc, taskArgs=(), executions=0, elapsedTime=0)
addSingleTask(taskFunc, taskArgs=())
disableCreateReactorThread()
executeNextTask()
getNextTaskId(**kwargs)
removeTask(**kwargs)
setMinValidPeriod(period)
setNumExecutionsForTask(**kwargs)
setTaskPeriod(taskId, period)