---

Thread Class Reference

a self starting Thread Object More...

#include <Utilities/Threads/interface/Thread.h>

Inheritance diagram for Thread:

List of all members.

Public Member Functions
	Thread ()
	constructor (in main thread)
unsigned int	tid () const
virtual	~Thread ()
	destructor (in main thread)
Static Public Member Functions
static unsigned int	self_tid ()
static void	verboseOff ()
static void	verboseOn ()
Public Attributes
std::ostream	cout
	ostream
Protected Member Functions
void	finalize ()
void	initialize ()
Private Member Functions
virtual void	abort ()=0
	called if exception trapped;
void	operator() ()
	the thread main.
virtual void	run ()=0
	body (in its own thread)
virtual void	terminate ()=0
	called if Terminate trapped
Private Attributes
boost::thread *	t1
unsigned int	tid_
Static Private Attributes
static bool	verbose = false
Friends
struct	Me
Classes
struct	Me
struct	Terminate
	thrown to terminate thread More...

---

Detailed Description

a self starting Thread Object

Definition at line 11 of file Thread.h.

---

Constructor & Destructor Documentation

Thread::Thread

(

)

constructor (in main thread)

Definition at line 27 of file Thread.cc.

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

Thread::~Thread

(

)

[virtual]

destructor (in main thread)

Definition at line 34 of file Thread.cc.

References GeneralUtilities::cout, lat::endl(), t1, and tid().

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

---

Member Function Documentation

virtual void Thread::abort

(

)

[private, pure virtual]

called if exception trapped;

Implemented in TSqueueConsumer< X, C >.

Referenced by operator()().

void Thread::finalize

(

void

)

[protected]

Definition at line 40 of file Thread.cc.

References GeneralUtilities::cout, lat::endl(), t1, tid(), and verbose.

Referenced by TSqueueConsumer< X, C >::~TSqueueConsumer().

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

void Thread::initialize

(

void

)

[protected]

Definition at line 29 of file Thread.cc.

References me, t1, and thread.

Referenced by TSqueueConsumer< X, C >::TSqueueConsumer().

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

void Thread::operator()

(

void

)

[private]

the thread main.

Definition at line 46 of file Thread.cc.

References abort(), className(), GeneralUtilities::cout, cout, Genexception::dump(), lat::endl(), run(), self_tid(), terminate(), tid_, and CMSexception::what().

                        {
  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();
  }
  
}

virtual void Thread::run

(

)

[private, pure virtual]

body (in its own thread)

Implemented in TSqueueConsumer< X, C >.

Referenced by operator()().

unsigned int Thread::self_tid

(

)

[static]

Definition at line 25 of file Thread.cc.

Referenced by operator()(), and TSqueueConsumer< X, C >::run().

{ return pthread_self();}

virtual void Thread::terminate

(

)

[private, pure virtual]

called if Terminate trapped

Implemented in TSqueueConsumer< X, C >.

Referenced by operator()().

unsigned int Thread::tid

(

)

const [inline]

Definition at line 21 of file Thread.h.

References tid_.

Referenced by finalize(), and ~Thread().

{ return tid_;}

void Thread::verboseOff

(

)

[static]

Definition at line 22 of file Thread.cc.

{ verbose=false;}

void Thread::verboseOn

(

)

[static]

Definition at line 20 of file Thread.cc.

{ verbose=true;}

---

Friends And Related Function Documentation

friend struct Me [friend]

Definition at line 46 of file Thread.h.

---

Member Data Documentation

std::ostream Thread::cout

ostream

Definition at line 51 of file Thread.h.

Referenced by operator()().

boost::thread* Thread::t1 [private]

Definition at line 24 of file Thread.h.

Referenced by finalize(), initialize(), and ~Thread().

unsigned int Thread::tid_ [private]

Definition at line 25 of file Thread.h.

Referenced by operator()(), and tid().

bool Thread::verbose = false [static, private]

Definition at line 37 of file Thread.h.

Referenced by finalize().

---

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

• Utilities/Threads/interface/Thread.h
• Utilities/Threads/src/Thread.cc

---