Concurrent processing of events in hybrid MP+MT workers
Compare changes
Files
7@@ -48,15 +48,16 @@ def _setupAtlasThreadedJob():
@@ -48,15 +48,16 @@ def _setupAtlasThreadedJob():
Modified AthenaMPTools/SharedHiveEvtQueueConsumer
so that it can process
events concurrently. In order to achieve that this tool is now using
the AthenaMtesEventLoopMgr
as the event processor, instead of the
previously used AthenaHiveEventLoopMgr
.
Also introduced a helper abstract interface AthenaKernel/IHybridProcessorHelper
to allow the SharedHiveEvtQueueConsumer
tool to call certain methods of the
AthenaMtesEventLoopMgr
.
Please note:
AthenaMT
these days anyway.CC @amete @gemmeren @elmsheus who have previously expressed some interest in hybrid MP+MT.