YouCompleteMe/cpp/ycm/ConcurrentStack.h

// Copyright (C) 2011, 2012  Strahinja Val Markovic  <val@markovic.io>
//
// This file is part of YouCompleteMe.
//
// YouCompleteMe is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// YouCompleteMe is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with YouCompleteMe.  If not, see <http://www.gnu.org/licenses/>.

#ifndef CONCURRENTSTACK_H_TGI0GOR6
#define CONCURRENTSTACK_H_TGI0GOR6

#include <boost/thread.hpp>
#include <boost/utility.hpp>
#include <stack>

namespace YouCompleteMe {

template <typename T>
class ConcurrentStack : boost::noncopyable {
public:

  void Push( const T &data ) {
    {
      boost::unique_lock< boost::mutex > lock( mutex_ );
      stack_.push( data );
    }

    condition_variable_.notify_one();
  }

  T Pop() {
    boost::unique_lock< boost::mutex > lock( mutex_ );

    while ( stack_.empty() ) {
      condition_variable_.wait( lock );
    }

    T top = stack_.top();
    stack_.pop();
    return top;
  }

private:
  std::stack< T > stack_;
  boost::mutex mutex_;
  boost::condition_variable condition_variable_;

};

} // namespace YouCompleteMe

#endif /* end of include guard: CONCURRENTSTACK_H_TGI0GOR6 */