/*
|
* =====================================================================================
|
*
|
* Filename: lock_free_queue.h
|
*
|
* Description:
|
*
|
* Version: 1.0
|
* Created: 2021年04月21日 14时03分27秒
|
* Revision: none
|
* Compiler: gcc
|
*
|
* Author: Li Chao (), lichao@aiotlink.com
|
* Organization:
|
*
|
* =====================================================================================
|
*/
|
|
#ifndef LOCK_FREE_QUEUE_KQWP70HT
|
#define LOCK_FREE_QUEUE_KQWP70HT
|
|
#include "shm.h"
|
#include <boost/interprocess/offset_ptr.hpp>
|
#include <boost/lockfree/queue.hpp>
|
|
using namespace bhome_shm;
|
|
typedef int64_t Data;
|
const int kQLen = 10;
|
class LockFreeQueue : private boost::lockfree::queue<Data,
|
boost::lockfree::allocator<Allocator<Data>>,
|
boost::lockfree::capacity<kQLen>>,
|
private boost::noncopyable
|
{
|
typedef boost::lockfree::queue<Data,
|
boost::lockfree::allocator<Allocator<Data>>,
|
boost::lockfree::capacity<kQLen>>
|
Queue;
|
|
public:
|
LockFreeQueue(SharedMemory &shm) :
|
Queue(shm.get_segment_manager()) {}
|
bool Read(Data &d) { return pop(d); }
|
bool Write(Data const &d) { return push(d); }
|
template <class Func>
|
bool Write(Data const &d, Func onWrite)
|
{
|
if (Write(d)) {
|
onWrite(d);
|
return true;
|
} else {
|
return false;
|
}
|
}
|
};
|
|
#endif // end of include guard: LOCK_FREE_QUEUE_KQWP70HT
|
