4 #include "common/Mutex.h"
5 #include "common/Cond.h"
16 typename std::list<T> entries;
18 QueueBucket() : lock("QueueRing::QueueBucket::lock") {}
19 QueueBucket(const QueueBucket& rhs) : lock("QueueRing::QueueBucket::lock") {
20 entries = rhs.entries;
23 void enqueue(const T& entry) {
25 if (entries.empty()) {
28 entries.push_back(entry);
32 void dequeue(T *entry) {
34 if (entries.empty()) {
37 assert(!entries.empty());
38 *entry = entries.front();
44 std::vector<QueueBucket> buckets;
47 std::atomic<int64_t> cur_read_bucket = { 0 };
48 std::atomic<int64_t> cur_write_bucket = { 0 };
51 QueueRing(int n) : buckets(n), num_buckets(n) {
54 void enqueue(const T& entry) {
55 buckets[++cur_write_bucket % num_buckets].enqueue(entry);
58 void dequeue(T *entry) {
59 buckets[++cur_read_bucket % num_buckets].dequeue(entry);