Method PrepareWrite

library/cpp/threading/chunk_queue/queue.h:171–183

    protected:
        T* PrepareWrite() {
            TChunk* chunk = Writer.Chunk;
            Y_ASSERT(chunk && !chunk->Next);

            if (chunk->Count != TChunk::MaxCount) {
                return chunk->GetPtr(chunk->Count);
            }

            chunk = new TChunk();
            AtomicSet(Writer.Chunk->Next, chunk);
            Writer.Chunk = chunk;
            return chunk->GetPtr(0);
        }

        void CompleteWrite() {
            AtomicSet(Writer.Chunk->Count, Writer.Chunk->Count + 1);