4 from Configurables
import HiveWhiteBoard, HiveSlimEventLoopMgr, RoundRobinSchedulerSvc, CPUCruncher,AlgResourcePool
11 scheduler = RoundRobinSchedulerSvc(OutputLevel=DEBUG)
13 slimeventloopmgr = HiveSlimEventLoopMgr(SchedulerName=
"RoundRobinSchedulerSvc",
16 whiteboard = HiveWhiteBoard(
"EventDataSvc")
19 algResPool=AlgResourcePool(OutputLevel=DEBUG)
22 DataOutputs = [
'/Event/a1'],
28 DataInputs = [
'/Event/a1'],
29 DataOutputs = [
'/Event/a2'])
32 DataInputs = [
'/Event/a1'],
33 DataOutputs = [
'/Event/a3'])
36 DataInputs = [
'/Event/a2',
'/Event/a3'],
37 DataOutputs = [
'/Event/a4'])
39 for algo
in [a1,a2,a3,a4]:
44 ExtSvc =[whiteboard,algResPool],
45 EventLoop = slimeventloopmgr,
46 TopAlg = [a1,a2,a3,a4],
47 MessageSvcType=
"InertMessageSvc")
Thread safe extension to the standard MessageSvc.
The Application Manager class.