ThreadInitTask Class Reference

Special TBB task used by ThreadPoolSvc to wrap execution of IThreadInitTools. More...

#include </builds/gaudi/Gaudi/GaudiHive/src/ThreadInitTask.h>

Collaboration diagram for ThreadInitTask:

Public Member Functions
	ThreadInitTask (ToolHandleArray< IThreadInitTool > &tools, boost::barrier *b, ISvcLocator *svcLocator, bool terminate=false)
void	operator() () const
	Execute the task.

Static Public Member Functions
static bool	execFailed ()

Private Attributes
std::vector< IThreadInitTool * >	m_tools
boost::barrier *	m_barrier = nullptr
SmartIF< ISvcLocator >	m_serviceLocator
bool	m_terminate = false

Static Private Attributes
static std::atomic< bool >	m_execFailed

Detailed Description

Special TBB task used by ThreadPoolSvc to wrap execution of IThreadInitTools.

Author

Charles Leggett

Definition at line 28 of file ThreadInitTask.h.

Constructor & Destructor Documentation

ThreadInitTask()

ThreadInitTask::ThreadInitTask ( ToolHandleArray< IThreadInitTool > & tools, boost::barrier * b, ISvcLocator * svcLocator, bool terminate = false )

inline

Definition at line 31 of file ThreadInitTask.h.

      : m_barrier( b ), m_serviceLocator( svcLocator ), m_terminate( terminate ) {
    m_tools.reserve( tools.size() );
    for ( auto& tool : tools ) { m_tools.push_back( tool.get() ); }
  }

Member Function Documentation

execFailed()

bool ThreadInitTask::execFailed ( )

inlinestatic

Definition at line 44 of file ThreadInitTask.h.

{ return m_execFailed; }

operator()()

void ThreadInitTask::operator()

(

)

const

Execute the task.

Will loop over IThreadInitTools and execute each one.

Definition at line 28 of file ThreadInitTask.cpp.

                                      {
 
  SmartIF<IMessageSvc> messageSvc( m_serviceLocator );
  MsgStream            log( messageSvc, "ThreadInitTask" );
 
  const auto debug = log.level() <= MSG::DEBUG;
 
  if ( debug )
    log << MSG::DEBUG << "execute() in thread 0x" << std::hex << pthread_self() << " at " << this << std::dec
        << "  state: " << ( m_terminate ? "terminate" : "initialize" ) << endmsg;
 
  if ( !m_terminate && Gaudi::Concurrency::ThreadInitDone ) {
    log << MSG::WARNING << "thread initialization has already been done on thread " << std::hex << pthread_self()
        << endmsg;
  }
 
  if ( m_tools.empty() ) {
    log << MSG::DEBUG << "no entries in Tool Array" << endmsg;
    if ( !m_terminate ) { Gaudi::Concurrency::ThreadInitDone = true; }
  } else {
    if ( debug ) log << MSG::DEBUG << "executing in thread 0x" << std::hex << pthread_self() << std::dec << endmsg;
 
    // only call terminate for threads that have been initialized
    if ( m_terminate && !Gaudi::Concurrency::ThreadInitDone ) {
      log << MSG::INFO << "Not calling terminateThread for thread 0x" << std::hex << pthread_self()
          << " as it has not been initialized" << endmsg;
    } else {
 
      for ( auto* tool : m_tools ) {
        try {
 
          if ( debug ) log << MSG::DEBUG << "calling IThreadInitTool " << tool->name() << endmsg;
 
          if ( !m_terminate ) {
            tool->initThread();
            Gaudi::Concurrency::ThreadInitDone = true;
          } else {
            tool->terminateThread();
          }
 
        } catch ( const GaudiException& exc ) {
          log << MSG::ERROR << "ThreadInitTool " << tool->name() << " in thread 0x" << std::hex << pthread_self()
              << std::dec << " threw GaudiException: " << exc << endmsg;
          m_execFailed = true;
        } catch ( const std::exception& exc ) {
          log << MSG::ERROR << "ThreadInitTool " << tool->name() << " in thread 0x" << std::hex << pthread_self()
              << std::dec << " threw std::exception: " << exc.what() << endmsg;
          m_execFailed = true;
        } catch ( ... ) {
          log << MSG::ERROR << "ThreadInitTool " << tool->name() << " in thread 0x" << std::hex << pthread_self()
              << std::dec << " threw unknown exception" << endmsg;
          m_execFailed = true;
        }
      }
    }
  }
 
  if ( m_barrier ) {
    log << MSG::DEBUG << "waiting at barrier in thread 0x" << std::hex << pthread_self() << std::dec << endmsg;
    m_barrier->wait();
  }
}

Member Data Documentation

m_barrier

boost::barrier* ThreadInitTask::m_barrier = nullptr

private

Definition at line 49 of file ThreadInitTask.h.

m_execFailed

std::atomic< bool > ThreadInitTask::m_execFailed

staticprivate

Definition at line 53 of file ThreadInitTask.h.

m_serviceLocator

SmartIF<ISvcLocator> ThreadInitTask::m_serviceLocator

private

Definition at line 50 of file ThreadInitTask.h.

m_terminate

bool ThreadInitTask::m_terminate = false

private

Definition at line 51 of file ThreadInitTask.h.

m_tools

std::vector<IThreadInitTool*> ThreadInitTask::m_tools

private

Definition at line 47 of file ThreadInitTask.h.

---

The documentation for this class was generated from the following files:

• GaudiHive/src/ThreadInitTask.h
• GaudiHive/src/ThreadInitTask.cpp