3 writes to _taskForInputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\JoinBlock.cs (3)
1267_taskForInputProcessing = new Task(static thisSharedResources => ((JoinBlockTargetSharedResources)thisSharedResources!).ProcessMessagesLoopCore(), this, 1289_taskForInputProcessing = null; 1391_taskForInputProcessing = null;
7 references to _taskForInputProcessing
System.Threading.Tasks.Dataflow (7)
Blocks\JoinBlock.cs (7)
216public Task? TaskForInputProcessing { get { return _joinBlock._sharedResources._taskForInputProcessing; } } 440public Task? TaskForInputProcessing { get { return _joinBlock._sharedResources._taskForInputProcessing; } } 839_nonGreedy!.PostponedMessages.Count == 0 && _sharedResources._taskForInputProcessing == null))) 1238_taskForInputProcessing == null && // not currently processing asynchronously 1274_ownerJoin, _taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 1279Exception? exception = Common.StartTaskSafe(_taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1319bool currentlyProcessing = _taskForInputProcessing != null;