asyncqueue.h

#ifndef ASYNCQUEUE_H_
#define ASYNCQUEUE_H_

#include <glib.h>

#include <vector>

template <typename T>
class Queue
{
public:
    Queue()
    {
        g_mutex_init(&mutex);
    }
    ~Queue()
    {

    }

    int count()
    {
        g_mutex_lock(&mutex);
        int ret = mQueue.count();
        g_mutex_unlock(&mutex);

        return ret;
    }

    T pop()
    {
        g_mutex_lock(&mutex);

        auto itr = mQueue.begin();

        T item = *itr;

        mQueue.erase(itr);

        g_mutex_unlock(&mutex);

        return item;
    }

    void append(T item)
    {
        g_mutex_lock(&mutex);

        g_cond_signal(&cond);

        mQueue.push_back(item);

        g_mutex_unlock(&mutex);
    }

private:
    GMutex mutex;
    std::vector<T> mQueue;
};

namespace amb
{

template <typename T>
void addQueueWatch( Queue<T> queue, std::function<void (Queue<T>)> callback);

}

#endif