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)