4 from Configurables
import HiveWhiteBoard, HiveSlimEventLoopMgr, SequentialSchedulerSvc, CPUCruncher,AlgResourcePool
11 scheduler = SequentialSchedulerSvc(OutputLevel=DEBUG)
13 slimeventloopmgr = HiveSlimEventLoopMgr(SchedulerName=
"SequentialSchedulerSvc",
16 whiteboard = HiveWhiteBoard(
"EventDataSvc")
19 algResPool=AlgResourcePool(OutputLevel=DEBUG)
25 a1.DataOutputs.output_0.Path =
'/Event/a1'
29 a2.DataInputs.input_0.Path =
'/Event/a1'
30 a2.DataOutputs.output_0.Path =
'/Event/a2'
34 a3.DataInputs.input_0.Path =
'/Event/a1'
35 a3.DataOutputs.output_0.Path =
'/Event/a3'
39 a4.DataInputs.input_0.Path =
'/Event/a2'
40 a4.DataInputs.input_1.Path =
'/Event/a3'
41 a4.DataOutputs.output_0.Path =
'/Event/a4'
44 for algo
in [a1,a2,a3,a4]:
49 ExtSvc =[whiteboard,algResPool],
50 EventLoop = slimeventloopmgr,
51 TopAlg = [a1,a2,a3,a4],
52 MessageSvcType=
"InertMessageSvc")
Thread safe extension to the standard MessageSvc.
The Application Manager class.