1 write to _messages
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
124_messages = (dataflowBlockOptions.MaxDegreeOfParallelism == 1) ?
14 references to _messages
System.Threading.Tasks.Dataflow (14)
Internal\TargetCore.cs (14)
79private object IncomingLock { get { return _messages; } } 162while (_messages.TryDequeue(out dummy)) ; 220_messages.Enqueue(new KeyValuePair<TInput, long>(messageValue!, messageId)); 244internal int InputCount { get { return _messages.GetCountSafe(IncomingLock); } } 359!_messages.IsEmpty || 380_messages.Count + (_boundingState != null ? _boundingState.PostponedMessages.Count : 0)); 429_messages.Enqueue(transferMessageWithId); 580if (_messages.TryDequeue(out messageWithId)) 635if (!forPostponementTransfer && _messages.TryDequeue(out result)) 717bool noMoreMessages = _decliningPermanently && _messages.IsEmpty; 730Debug.Assert((_decliningPermanently && _messages.IsEmpty) || CanceledOrFaulted, "There must be no more messages."); 772IProducerConsumerQueue<KeyValuePair<TInput, long>> messages = _messages; 854internal int InputCount { get { return _target._messages.Count; } } 856internal IEnumerable<TInput> InputQueue { get { return _target._messages.Select(static kvp => kvp.Key).ToList(); } }