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