tmq_pipe.h

来自「Generic template class library for messa」· C头文件 代码 · 共 35 行

#pragma once 

#include <JTC/JTC.h>

template <class T, class Container>
class TMQ_Pipe
{
  public:
    void post(
        T& theData
    )
    {
	theMutex.lock() ;
	theContainer.post( theData );
	theMutex.unlock() ;
    }

    bool get(
        T& theData,
	struct timeval* ptrTimeVal = NULL 
    )
    {
	theData = theContainer.get(ptrTimeVal);
	return true;
    }

  private:
    JTCRecursiveMutex theMutex ;

    Container theContainer;
};


#endif /* __TMQ_PIPE_H__ */