ActionBlock() [5/5]

System.Threading.Tasks.Dataflow.ActionBlock< TInput >.ActionBlock ( Delegate action, ExecutionDataflowBlockOptions dataflowBlockOptions )

inlineprivate

Definition at line 172 of file ActionBlock.cs.

    {
        ActionBlock<TInput> actionBlock = this;
        if ((object)action == null)
        {
            throw new ArgumentNullException("action");
        }
        if (dataflowBlockOptions == null)
        {
            throw new ArgumentNullException("dataflowBlockOptions");
        }
        dataflowBlockOptions = dataflowBlockOptions.DefaultOrClone();
        Action<TInput> syncAction = action as Action<TInput>;
        if (syncAction != null && dataflowBlockOptions.SingleProducerConstrained && dataflowBlockOptions.MaxDegreeOfParallelism == 1 && !dataflowBlockOptions.CancellationToken.CanBeCanceled && dataflowBlockOptions.BoundedCapacity == -1)
        {
            _spscTarget = new SpscTargetCore<TInput>(this, syncAction, dataflowBlockOptions);
        }
        else
        {
            if (syncAction != null)
            {
                _defaultTarget = new TargetCore<TInput>(this, delegate(KeyValuePair<TInput, long> messageWithId)
                {
                    actionBlock.ProcessMessage(syncAction, messageWithId);
                }, null, dataflowBlockOptions, TargetCoreOptions.RepresentsBlockCompletion);
            }
            else
            {
                Func<TInput, Task> asyncAction = action as Func<TInput, Task>;
                _defaultTarget = new TargetCore<TInput>(this, delegate(KeyValuePair<TInput, long> messageWithId)
                {
                    actionBlock.ProcessMessageWithTask(asyncAction, messageWithId);
                }, null, dataflowBlockOptions, TargetCoreOptions.UsesAsyncCompletion | TargetCoreOptions.RepresentsBlockCompletion);
            }
            Common.WireCancellationToComplete(dataflowBlockOptions.CancellationToken, Completion, delegate(object state)
            {
                ((TargetCore<TInput>)state).Complete(null, dropPendingMessages: true);
            }, _defaultTarget);
        }
        DataflowEtwProvider log = DataflowEtwProvider.Log;
        if (log.IsEnabled())
        {
            log.DataflowBlockCreated(this, dataflowBlockOptions);
        }
    }

References System.Threading.Tasks.Dataflow.ActionBlock< TInput >._defaultTarget, System.Threading.Tasks.Dataflow.ActionBlock< TInput >._spscTarget, System.action, System.Threading.Tasks.Dataflow.ActionBlock< TInput >.Completion, System.Threading.Tasks.Dataflow.Internal.DataflowEtwProvider.Log, System.state, and System.Threading.Tasks.Dataflow.Internal.Common.WireCancellationToComplete().