1 write to _sharedResources
System.Threading.Tasks.Dataflow (1)
14 references to _sharedResources
System.Threading.Tasks.Dataflow (14)
Blocks\JoinBlock.cs (14)
62if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2>)owningSource)._sharedResources.OnItemsRemoved(count);
66static owningSource => ((JoinBlock<T1, T2>)owningSource)._sharedResources.CompleteEachTarget(),
78Volatile.Write(ref _sharedResources!._hasExceptions, true);
82targets[0] = _target1 = new JoinBlockTarget<T1>(_sharedResources);
83targets[1] = _target2 = new JoinBlockTarget<T2>(_sharedResources);
104dataflowBlockOptions.CancellationToken, _source.Completion, static (state, _) => ((JoinBlock<T1, T2>)state!)._sharedResources.CompleteEachTarget(), this);
151Debug.Assert(_sharedResources != null, "_sharedResources not initialized");
152Debug.Assert(_sharedResources._exceptionAction != null, "_sharedResources._exceptionAction not initialized");
154lock (_sharedResources.IncomingLock)
156if (!_sharedResources._decliningPermanently) _sharedResources._exceptionAction(exception);
219public long JoinsCreated { get { return _joinBlock._sharedResources._joinsCreated; } }
222public Task? TaskForInputProcessing { get { return _joinBlock._sharedResources._taskForInputProcessing; } }
229public bool IsDecliningPermanently { get { return _joinBlock._sharedResources._decliningPermanently; } }