ReEntAlg.cpp

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2026 CERN for the benefit of the LHCb and ATLAS collaborations *
*                                                                                   *
* This software is distributed under the terms of the Apache version 2 licence,     *
* copied verbatim in the file "LICENSE".                                            *
*                                                                                   *
* In applying this licence, CERN does not waive the privileges and immunities       *
* granted to it by virtue of its status as an Intergovernmental Organization        *
* or submit itself to any jurisdiction.                                             *
\***********************************************************************************/
#include "ReEntAlg.h"
#include <GaudiKernel/ISvcLocator.h>
#include <GaudiKernel/MsgStream.h>
 
#include <chrono>
#include <thread>
 
DECLARE_COMPONENT( ReEntAlg )
 

 
ReEntAlg::ReEntAlg( const std::string& name, ISvcLocator* pSvcLocator ) : Gaudi::Algorithm( name, pSvcLocator ) {}
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode ReEntAlg::initialize() {
  auto sc = Gaudi::Algorithm::initialize();
  if ( !sc ) return sc;
  info() << "initialize()" << endmsg;
  return sc;
}
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode ReEntAlg::execute( const EventContext& ctx ) const {
 
  // Increment concurrent executions and update max if needed
  int val = ++m_concurrentExecs;
  int max = m_maxConcurrency.load();
  while ( val > max && !m_maxConcurrency.compare_exchange_weak( max, val ) )
    ;
 
  // wait a little bit to make sure the printouts are in a stable order
  std::this_thread::sleep_for( std::chrono::milliseconds( 50 * ctx.slot() ) );
 
  info() << "execute(): context: (" << ctx << ") index: " << index() << " cardinality: " << cardinality() << endmsg;
 
  std::chrono::milliseconds dt{ m_sleep + ctx.slot() * 500 };
  std::this_thread::sleep_for( dt );
 
  info() << "... done in " << dt.count() << " ms for " << ctx << endmsg;
  std::this_thread::sleep_for( std::chrono::milliseconds( 50 ) );
 
  // Decrement concurrent executing counter
  --m_concurrentExecs;
 
  return StatusCode::SUCCESS;
}
 
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
 
StatusCode ReEntAlg::finalize() {
  info() << "Maximum number of concurrent executions: " << m_maxConcurrency << endmsg;
  return Gaudi::Algorithm::finalize();
}