27 #ifndef WF_RINGBUFFER_API_H_
28 #define WF_RINGBUFFER_API_H_
51 uint64_t loop =
x_ & 0x00FFFFFFFFFFFFFF;
52 uint64_t tid =
x_ >> 56;
53 return "TID: " + std::to_string(tid) +
" LC: " + std::to_string(loop);
68 std::string temp =
container->debug_string();
69 std::cout << temp << std::endl;
74 return "WF RingBuffer";
85 WrapperType *temp =
new WrapperType(value);
94 value = temp->value();
104 #endif // WF_RINGBUFFER_API_H_
void detach_thread()
Definition: wf_ringbuffer_api.h:82
Thread local information.
Definition: thread_context.h:62
container_t * container
Definition: wf_ringbuffer_api.h:101
WrapperType(Value x)
Definition: wf_ringbuffer_api.h:47
map_t * container
Definition: cliff_api.h:102
bool enqueue(Value value)
Definition: wf_ringbuffer_api.h:84
const Value x_
Definition: wf_ringbuffer_api.h:56
void attach_thread()
Definition: blank_api.h:40
This is a non-blocking FIFO ring buffer design that was made wait-free by applying a progress assuran...
Definition: ring_buffer.h:73
Value value()
Definition: wf_ringbuffer_api.h:48
tervel::containers::wf::RingBuffer< WrapperType * > container_t
Definition: wf_ringbuffer_api.h:41
bool dequeue(Value &value)
Definition: wf_ringbuffer_api.h:90
RingBuffer value class, values stored in the class must extend it.
Definition: ring_buffer.h:92
uint64_t Value
Definition: testObject.h:59
Contains shared information that should be accessible by all threads.
Definition: tervel.h:39
std::string toString()
Definition: wf_ringbuffer_api.h:49
Definition: blank_api.h:31
TestClass(size_t num_threads, size_t capacity)
Definition: wf_ringbuffer_api.h:61
Definition: wf_ringbuffer_api.h:45
tervel::Tervel * tervel_obj
Definition: wf_hashmap_api.h:98
~TestClass()
Definition: wf_ringbuffer_api.h:67
std::string toString()
Definition: wf_ringbuffer_api.h:73