SingleBlockingTaskAvalancheScheduler.py

Go to the documentation of this file.

#!/usr/bin/env gaudirun.py
 
"""
The simplest possible configuration for preemptive scheduling of single blocking algorithm.
"""
 
from Configurables import (
    AvalancheSchedulerSvc,
    CPUCruncher,
    CPUCrunchSvc,
    HiveSlimEventLoopMgr,
    HiveWhiteBoard,
)
from Gaudi.Configuration import *
 
# metaconfig
evtMax = 7
evtslots = 3
algosInFlight = 0
blockingAlgosInFlight = 3
 
CPUCrunchSvc(shortCalib=True)
 
whiteboard = HiveWhiteBoard("EventDataSvc", EventSlots=evtslots, OutputLevel=INFO)
 
slimeventloopmgr = HiveSlimEventLoopMgr(
    SchedulerName="AvalancheSchedulerSvc", OutputLevel=INFO
)
 
AvalancheSchedulerSvc(
    ThreadPoolSize=algosInFlight,
    PreemptiveBlockingTasks=True,
    MaxBlockingAlgosInFlight=blockingAlgosInFlight,
    OutputLevel=VERBOSE,
)
 
blockingAlg = CPUCruncher(
    name="BlockingAlg",
    avgRuntime=2.0,
    Cardinality=3,
    Blocking=True,  # tag algorithm as blocking
    SleepFraction=0.7,  # simulate blocking nature
    OutputLevel=DEBUG,
)
 
ApplicationMgr(
    EvtMax=evtMax,
    EvtSel="NONE",
    ExtSvc=[whiteboard],
    EventLoop=slimeventloopmgr,
    TopAlg=[blockingAlg],
    MessageSvcType="InertMessageSvc",
    OutputLevel=INFO,
)