Method Dequeue

library/cpp/threading/chunk_queue/queue.h:469–485

        }

        bool Dequeue(T& value) {
            size_t readPos = GetCycleCount();
            for (size_t i = 0; i < Concurrency; ++i) {
                TQueueType& queue = Queues[readPos++ % Concurrency];
                if (queue.ReadLock.IsLocked()) {
                    continue;
                }
                TTryGuard guard{queue.ReadLock};
                if (!guard) {
                    continue;
                }
                if (queue.Dequeue(value)) {
                    return true;
                }
            }
            return false;
        }

        bool IsEmpty() {
            for (size_t i = 0; i < Concurrency; ++i) {