Method TryEnqueue

library/cpp/threading/chunk_queue/queue.h:293–311

        template <typename TT>
        bool TryEnqueue(TT&& value, ui64 tag) {
            for (size_t i = 0; i < Concurrency; ++i) {
                TQueueType& queue = Queues[i];
                if (queue.WriteLock.IsLocked()) {
                    continue;
                }
                TTryGuard guard{queue.WriteLock};
                if (!guard) {
                    continue;
                }
                TEntry* entry = queue.PrepareWrite();
                Y_ASSERT(entry);
                TTypeHelper::Write(&entry->Value, std::forward<TT>(value));
                entry->Tag = tag;
                queue.CompleteWrite();
                return true;
            }
            return false;
        }

        TEntry* PrepareRead(size_t& index) {
            TEntry* entry = nullptr;