#include <unrelacy.h>
+#include <atomic>
#include "eventcount.h"
public:
spsc_queue()
{
- node* n = RL_NEW node ();
+ node* n = new node ();
head = n;
tail = n;
}
~spsc_queue()
{
RL_ASSERT(head == tail);
- RL_DELETE((node*)head($));
+ delete ((node*)head($));
}
void enqueue(T data)
{
- node* n = RL_NEW node (data);
+ node* n = new node (data);
head($)->next.store(n, std::memory_order_release);
head = n;
ec.signal_relaxed();
rl::var<T> data;
node(T data = T())
- : next(0)
- , data(data)
- {}
+ : data(data)
+ {
+ next = 0;
+ }
};
rl::var<node*> head;
if (0 == n)
return 0;
T data = n->data($);
- RL_DELETE(t);
+ delete (t);
tail = n;
return data;
}