ConsumeAsyncIfNecessary()

void System.Threading.Tasks.Dataflow.BufferBlock< T >.ConsumeAsyncIfNecessary ( bool isReplacementReplica = false )

inlinepackage

Definition at line 243 of file BufferBlock.cs.

    {
        if (_targetDecliningPermanently || _boundingState.TaskForInputProcessing != null || _boundingState.PostponedMessages.Count <= 0 || !_boundingState.CountIsLessThanBound)
        {
            return;
        }
        _boundingState.TaskForInputProcessing = new Task(delegate(object state)
        {
            ((BufferBlock<T>)state).ConsumeMessagesLoopCore();
        }, this, Common.GetCreationOptionsForTask(isReplacementReplica));
        DataflowEtwProvider log = DataflowEtwProvider.Log;
        if (log.IsEnabled())
        {
            log.TaskLaunchedForMessageHandling(this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, _boundingState.PostponedMessages.Count);
        }
        Exception ex = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler);
        if (ex != null)
        {
            Task.Factory.StartNew(delegate(object exc)
            {
                CompleteCore((Exception)exc, storeExceptionEvenIfAlreadyCompleting: true, revertProcessingState: true);
            }, ex, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
        }
    }

References System.Threading.Tasks.Dataflow.BufferBlock< T >._boundingState, System.Threading.Tasks.Dataflow.BufferBlock< T >._source, System.Threading.Tasks.Dataflow.BufferBlock< T >._targetDecliningPermanently, System.Threading.Tasks.Dataflow.BufferBlock< T >.CompleteCore(), System.Threading.Tasks.Dataflow.Internal.SourceCore< TOutput >.DataflowBlockOptions, System.Threading.Tasks.TaskScheduler.Default, System.Threading.Tasks.Task< TResult >.Factory, System.Threading.Tasks.Dataflow.Internal.Common.GetCreationOptionsForTask(), System.Threading.Tasks.Dataflow.Internal.DataflowEtwProvider.Log, System.Threading.CancellationToken.None, System.Threading.Tasks.Dataflow.Internal.Common.StartTaskSafe(), System.state, System.Threading.Tasks.Dataflow.Internal.BoundingStateWithPostponedAndTask< TInput >.TaskForInputProcessing, and System.Threading.Tasks.Dataflow.DataflowBlockOptions.TaskScheduler.

Referenced by System.Threading.Tasks.Dataflow.BufferBlock< T >.ConsumeMessagesLoopCore(), and System.Threading.Tasks.Dataflow.BufferBlock< T >.OnItemsRemoved().