IOCP 제네릭 큐를 아래의 곳에서 구했습니다.

하지만, 컴파일이 제대로 안되네요.. ㅠㅠ

혹시 사용하고 계신 Class나 방법을 좀 가르쳐 주세요..  ^^

Embarcadero 홈페이지에서는 Delphi용 예제 밖에 구할수가 없네요.. ㅠㅠ



출처 : CONCURRENT QUEUE – C++11
http://juanchopanzacpp.wordpress.com/2013/02/26/concurrent-queue-c11/


#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>

template <typename T>
class Queue
{
public:

  T pop()
  {
    std::unique_lock<std::mutex> mlock(mutex_);
    while (queue_.empty())
    {
      cond_.wait(mlock);
    }
    auto item = queue_.front();
    queue_.pop();
    return item;
  }

  void pop(T& item)
  {
    std::unique_lock<std::mutex> mlock(mutex_);
    while (queue_.empty())
    {
      cond_.wait(mlock);
    }
    item = queue_.front();
    queue_.pop();
  }

  void push(const T& item)
  {
    std::unique_lock<std::mutex> mlock(mutex_);
    queue_.push(item);
    mlock.unlock();
    cond_.notify_one();
  }

  void push(T&& item)
  {
    std::unique_lock<std::mutex> mlock(mutex_);
    queue_.push(std::move(item));
    mlock.unlock();
    cond_.notify_one();
  }

private:
  std::queue<T> queue_;
  std::mutex mutex_;
  std::condition_variable cond_;
};