MultiShotBarrier.h

#ifndef CARMA_UTIL_MULTISHOTBARRIER_H
#define CARMA_UTIL_MULTISHOTBARRIER_H

#include "carma/util/PthreadCond.h"
#include "carma/util/PthreadMutex.h"

namespace carma {
namespace util {

class MultiShotBarrier {
    public:

        explicit MultiShotBarrier( size_t initialSatisfyCount );
        
        explicit MultiShotBarrier( );

        
        virtual ~MultiShotBarrier( );
        
        void reset( size_t satisfyCount );

        void wait( );
        
    private:

        // No copying
        MultiShotBarrier( const MultiShotBarrier & rhs );
        MultiShotBarrier & operator=( const MultiShotBarrier & rhs );

        size_t       satisfyCount_;
        PthreadMutex guard_;
        PthreadCond  satisfiedCond_;
        size_t       waitCount_;

        size_t       activeWaiters_;
        PthreadMutex activeWaitersGuard_;

};


}  // namespace carma::util
}  // namespace carma

#endif