concurrentQueue.h

Go to the documentation of this file.

/*
 * Copyright 2017 Fraunhofer Institute for Manufacturing Engineering and Automation (IPA)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
 
#include <iostream>
#include <boost/thread.hpp>
#include <boost/circular_buffer.hpp>
 
template<typename T>
class ConcurrentQueue
{
private:
    boost::circular_buffer<T> _queue;
    mutable boost::mutex _mutex;
    boost::condition_variable _condition;
public:
    ConcurrentQueue()
        : _queue(2)
        {
        }
 
    bool empty() const
    {
        boost::mutex::scoped_lock lock(_mutex);
        return _queue.empty();
    }
 
    void push(T const& data)
    {
        boost::mutex::scoped_lock lock(_mutex);
        _queue.push_back(data);
        lock.unlock();
        _condition.notify_one();
    }
 
    bool pop(T& data)
    {
        boost::mutex::scoped_lock lock(_mutex);
        if(_queue.empty())
            return false;
 
        data = _queue.front();
        _queue.pop_front();
 
        return true;
    }
 
    void wait_pop(T& data)
    {
        boost::mutex::scoped_lock lock(_mutex);
        while(_queue.empty())
                _condition.wait(lock);
 
        data=_queue.front();
        _queue.pop_front();
    }
};