---

Thread.cc

Go to the documentation of this file.

#include "Utilities/Threads/interface/Thread.h"
#include "Utilities/General/interface/MutexUtils.h"
#include "Utilities/General/interface/CMSexception.h"
#include "Utilities/General/interface/UncatchedException.h"
#include "Utilities/General/interface/ClassName.h"
#include "Utilities/General/interface/GeneralVerbosity.h"
#include "Utilities/General/interface/DecoratedSB.h"
#include "Utilities/Timing/interface/LinuxCPUTime.h"
#include "Utilities/General/interface/ioutils.h"

#include <ostream>
#include <iostream>
#include <string>

using std::endl;
using std::string;

bool Thread::verbose=false;

void Thread::verboseOn() { verbose=true;}

void Thread::verboseOff() { verbose=false;}


unsigned int Thread::self_tid() { return pthread_self();}

Thread::Thread() : t1(0), cout(std::cout.rdbuf()){}

void Thread::initialize() {
  Me me(*this);
  t1 = new boost::thread(me);
}

Thread::~Thread(){
  if (t1)
    GeneralUtilities::cout << " thread  " << tid() << "still active??? "  << std::endl;
  delete t1; t1=0;
}

void Thread::finalize() {
  if (Thread::verbose) GeneralUtilities::cout << "wait for thread " << tid() << std::endl;
  (*t1).join();
  delete t1; t1=0;
}

void Thread::operator()() {
  tid_ = self_tid();
  if (verbose) 
    GeneralUtilities::cout << " thread starts.." << self_tid() << std::endl;
  
  try{
#ifdef __linux__
      LinuxElapsedTime lt(string("in Thread ")+toa()(tid_));
#endif
      run();
  }
  catch ( Terminate ) {
    if (verbose)
      GeneralUtilities::cout << "thread " 
           << self_tid() << " terminates " << std::endl;
    terminate();
  }
  catch ( GenTerminate & cexp ) {
    GeneralUtilities::cout << "thread " 
         << self_tid() << " termination triggered by " << std::endl;
    cexp.dump(cout,true);
    terminate();
  }
  catch ( CMSexception & cexp) {
    GeneralUtilities::cout << "thread " 
         << self_tid() << " caught  CMS exception (" 
         << className(cexp) 
         << ") :" << endl;
    GeneralUtilities::cout << cexp.what() << std::endl;
    GeneralUtilities::cout << " inform producer...." << std::endl;
    UncatchedException uce;
    assert(&uce != 0); // Avoids warning message for unused variable uce.
    abort();
  }
  catch (...) {
    GeneralUtilities::cout << "thread " 
         << self_tid() << " caught unknown exception " << std::endl;    
    GeneralUtilities::cout << " inform producer...." << std::endl;
    UncatchedException uce;
    assert(&uce != 0); // Avoids warning message for unused variable uce.
    abort();
  }
  
}

LockMutex::Mutex Capri::glMutex;

namespace {
  struct LocBuilder {
    LocBuilder() : 
      cyan(std::cout.rdbuf(),"",""),
      me(&cyan) {
    }
    DefDecoratedSB cyan;
   std::ostream me;
  };

}

std::ostream & TSafeOstream() {
  return ThreadSingleton<LocBuilder>::instance().me;
}

---