Method PrepareRead

library/cpp/threading/chunk_queue/queue.h:189–212

        }

        T* PrepareRead() {
            TChunk* chunk = Reader.Chunk;
            Y_ASSERT(chunk);

            for (;;) {
                size_t writerCount = AtomicGet(chunk->Count);
                if (Reader.Count != writerCount) {
                    return chunk->GetPtr(Reader.Count);
                }

                if (writerCount != TChunk::MaxCount) {
                    return nullptr;
                }

                chunk = AtomicGet(chunk->Next);
                if (!chunk) {
                    return nullptr;
                }

                delete Reader.Chunk;
                Reader.Chunk = chunk;
                Reader.Count = 0;
            }
        }

        void CompleteRead() {
            ++Reader.Count;