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 Gaudi.Configuration import *
from Configurables import HiveWhiteBoard, HiveSlimEventLoopMgr, AvalancheSchedulerSvc, CPUCruncher, CPUCrunchSvc
 
# 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.,
    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)