R>class request
R>{
R>  // your data
R>};

R>class request_queue
R>{
R>public:
R>  void enqueue(request* req)
R>  {
R>    bool notify = false;
R>    {
R>      boost::unique_lock<boost::mutex> lock (mtx);
R>      notify = queue.empty();
R>      queue.push_back(req);
R>    }      
R>    if (notify)
R>      cv.notify_one();
R>  }
  
R>  request* dequeue()
R>  {
R>      boost::unique_lock<boost::mutex> lock (mtx);
R>      while (queue.empty())
R>        cv.wait(lock);
R>      request* req = queue.front();
R>      queue.pop_front();
R>      return req;
R>  }
  
R>private:
R>  boost::mutex mtx;
R>  boost::condition_variable cv;
R>  std::queue<request*> queue;
R>};


R>void server_thread()
R>{
R>  // enqueue 0 to the queue to stop the server thread
R>  while (request* req = queue.dequeue())
R>    process(req);
R>}

R>void client_thread()
R>{
R>  while (...)
R>  {
R>    request* req = create_request();
R>    queue.enqueue(req);
R>  }
R>}
R>