src/base/buffer_pool.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef SENDS_BUFFER_POOL_HH
#define SENDS_BUFFER_POOL_HH

//#include "tbb/concurrent_queue.h"
#include "mt_queue.hh"

namespace sends {

    class buffer;

    class buffer_pool {
    public:
        typedef thread::mt_queue<buffer*> buffer_queue;
        //typedef tbb::concurrent_queue<buffer*> buffer_queue;
    public:
        buffer_pool(long nbuf, long lbuf);

        ~buffer_pool(void);

        buffer* get_buffer(void);

        buffer* get_buffer_now(void);

        void return_buffer(buffer* buf);
    private:
        buffer_queue mQueue;
    };
}

#endif

---