Go to the source code of this file.
◆ main()
Definition at line 42 of file main.cpp.
46 {
"ApplicationMgr.JobOptionsType",
"\"NONE\"" },
47 {
"ApplicationMgr.EventLoop",
"\"Gaudi::Examples::QueueingEventLoopMgr/QueueingEventLoopMgr\"" },
48 {
"ApplicationMgr.OutputLevel",
"3" },
49 {
"ApplicationMgr.TopAlg",
"['GaudiTesting::SleepyAlg/Alg1']" },
50 {
"Alg1.SleepTime",
"1" },
51 {
"QueueingEventLoopMgr.OutputLevel",
"2" },
52 {
"QueueingEventLoopMgr.Capacity",
"3" } };
62 app->initialize().ignore();
71 app->start().ignore();
85 for (
std::size_t batch = 1; batch <= n_of_batches; ++batch ) {
89 log <<
MSG::INFO <<
" (pretend we need time so that the processing thread drains the input queue)"
92 log <<
MSG::INFO <<
" (all events in the queue should have been processed by now)" <<
endmsg;
96 auto ctx = qep->createEventContext();
104 while ( !ready.
empty() ) {
113 if (
auto result = qep->pop() ) {
121 while ( !qep->empty() ) {
122 if (
auto result = qep->pop() ) {
135 app->stop().ignore();
136 app->finalize().ignore();