Collaboration diagram for Barrier:

Public Member Functions
	Barrier (int numThreads)
void	sync (int id, bool isMaster=false)
Static Public Attributes
static volatile int	sPreWaitCnt = 0
static volatile int	sPostWaitCnt = 0
Protected Attributes
Condition	mCond
Mutex	mMutex
volatile int	mCurId
volatile int	mHaveCnt
int	mWantCnt

Detailed Description

Definition at line 24 of file testRandomThread.cxx.

Constructor & Destructor Documentation

Barrier::Barrier ( int numThreads ) [inline]

Definition at line 26 of file testRandomThread.cxx.

         : mCurId(0), mHaveCnt(0), mWantCnt(numThreads) { };

Member Function Documentation

void Barrier::sync	(	int	id,
		bool	isMaster = `false`
	)

Definition at line 45 of file testRandomThread.cxx.

Referenced by doThreadedTest().

{
   Lock datalock(mMutex);
   if ( isMaster )
   {
      mHaveCnt = 0;
      mCurId = id;
      mCond.broadcast();
   }
   else
   {
      while ( mCurId != id )
      {
         ++sPreWaitCnt;
         mCond.wait(mMutex);
      }
      ++mHaveCnt;
      mCond.broadcast();
   }
   while ( mCurId==id && mHaveCnt < mWantCnt )
   {
       ++sPostWaitCnt;
       mCond.wait(mMutex);
   }
}