| 70 | |
| 71 | int count() const { return _queue_length.load(std::memory_order_relaxed); } |
| 72 | int decrease_count(int count = 1) |
| 73 | { |
| 74 | _queue_length_counter->add((int64_t)(-count)); |
| 75 | return _queue_length.fetch_sub(count, std::memory_order_relaxed) - count; |
| 76 | } |
| 77 | int increase_count(int count = 1) |
| 78 | { |
| 79 | _queue_length_counter->add(count); |