More...

template <class T>
class EventQueue : public AutoResetEvent
{
public:

 EventQueue() : AutoResetEvent(), m_queue(), m_cs()
 {
 }

 virtual ~EventQueue()
 {
 }

 void Clear()
 {  
  ScopedLock synch(m_cs);
  while(!m_queue.empty())
  {
   m_queue.pop();
  }
 }

 int Size()
 {
  ScopedLock lock(m_cs);
  return m_queue.size();
 }

 bool Empty()
 {
  ScopedLock synch(m_cs);
  return m_queue.empty();
 }

 void Push(T node)
 {
  ScopedLock synch(m_cs);

  m_queue.push(node);

  // 큐가 빈 상태에서 데이터가 들어오면 알린다.
  if(1 == m_queue.size())
   Set();
 }

 bool Pop(T& output)
 {
  ScopedLock synch(m_cs);

  if(m_queue.empty())
   return false;

  output = m_queue.front();
  m_queue.pop();

  return true;
 } 

 // outs must valid and classic-array or 0-base operator[] overloading
 int Pop(T* outs, int max)
 {
  if(0 >= max || 0 == outs)
   return 0;

  ScopedLock synch(m_cs);

  int count = 0;

  for(count = 0 ; count < max ; count++)
  {
   if(m_queue.empty())
    return count;

   outs[count] = m_queue.front();
   m_queue.pop();
  }
  return count;
 } 

private:
 std::queue<T>  m_queue;
 CriticalSection  m_cs;
};

////////////////////////////////////////////////////////////////////////
사용하는 소스 정리중...