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.outKeys = [
'/Event/a1']
29 a2.inpKeys = [
'/Event/a1']
30 a2.outKeys = [
'/Event/a2']
34 a3.inpKeys = [
'/Event/a1']
35 a3.outKeys = [
'/Event/a3']
39 a4.inpKeys = [
'/Event/a2',
'/Event/a3']
40 a4.outKeys = [
'/Event/a4']
43 for algo
in [a1,a2,a3,a4]:
48 ExtSvc =[whiteboard,algResPool],
49 EventLoop = slimeventloopmgr,
50 TopAlg = [a1,a2,a3,a4],
51 MessageSvcType=
"InertMessageSvc")
Thread safe extension to the standard MessageSvc.
The Application Manager class.