TryWrite()

override bool System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelWriter.TryWrite ( T item )

inline

Definition at line 178 of file UnboundedChannel.cs.

        {
            UnboundedChannel<T> parent = _parent;
            AsyncOperation<bool> listTail;
            while (true)
            {
                AsyncOperation<T> asyncOperation = null;
                listTail = null;
                lock (parent.SyncObj)
                {
                    if (parent._doneWriting != null)
                    {
                        return false;
                    }
                    if (parent._blockedReaders.IsEmpty)
                    {
                        parent._items.Enqueue(item);
                        listTail = parent._waitingReadersTail;
                        if (listTail == null)
                        {
                            return true;
                        }
                        parent._waitingReadersTail = null;
                    }
                    else
                    {
                        asyncOperation = parent._blockedReaders.DequeueHead();
                    }
                }
                if (asyncOperation == null)
                {
                    break;
                }
                if (asyncOperation.TrySetResult(item))
                {
                    return true;
                }
            }
            ChannelUtilities.WakeUpWaiters(ref listTail, result: true);
            return true;
        }

References System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelWriter._parent, System.item, and System.Threading.Channels.ChannelUtilities.WakeUpWaiters().

Referenced by System.Threading.Channels.UnboundedChannel< T >.UnboundedChannelWriter.WriteAsync().