3 writes to _taskForInputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\JoinBlock.cs (3)
1282_taskForInputProcessing = new Task(static thisSharedResources => ((JoinBlockTargetSharedResources)thisSharedResources!).ProcessMessagesLoopCore(), this, 1304_taskForInputProcessing = null; 1406_taskForInputProcessing = null;
7 references to _taskForInputProcessing
System.Threading.Tasks.Dataflow (7)
Blocks\JoinBlock.cs (7)
222public Task? TaskForInputProcessing { get { return _joinBlock._sharedResources._taskForInputProcessing; } } 452public Task? TaskForInputProcessing { get { return _joinBlock._sharedResources._taskForInputProcessing; } } 851_nonGreedy!.PostponedMessages.Count == 0 && _sharedResources._taskForInputProcessing == null))) 1253_taskForInputProcessing == null && // not currently processing asynchronously 1289_ownerJoin, _taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 1294Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1334bool currentlyProcessing = _taskForInputProcessing != null;