3 instantiations of ActionBlock
Microsoft.Build (2)
BackEnd\BuildManager\BuildManager.cs (1)
624
_workQueue = new
ActionBlock
<Action>(action => ProcessWorkQueue(action));
BackEnd\Components\BuildRequestEngine\BuildRequestEngine.cs (1)
199
_workQueue = new
ActionBlock
<Action>(action => action.Invoke());
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2465
Target = new
ActionBlock
<TOutput>((Func<TOutput, Task>)ProcessItemAsync, DataflowBlock._nonGreedyExecutionOptions);
20 references to ActionBlock
Microsoft.Build (3)
BackEnd\BuildManager\BuildManager.cs (1)
238
private
ActionBlock
<Action>? _workQueue;
BackEnd\Components\BuildRequestEngine\BuildRequestEngine.cs (2)
62
private
ActionBlock
<Action> _workQueue;
1375
ActionBlock
<Action> queue = _workQueue;
System.Threading.Tasks.Dataflow (17)
Base\DataflowBlock.cs (2)
247
/// for the item to actually be processed (for example, <see cref="System.Threading.Tasks.Dataflow.
ActionBlock
{T}"/>
2441
internal readonly
ActionBlock
<TOutput> Target;
Base\DataflowBlockOptions.cs (1)
202
/// as <see cref="
ActionBlock
{T}"/> and <see cref="TransformBlock{TInput,TOutput}"/>.
Blocks\ActionBlock.cs (14)
22
/// <typeparam name="TInput">Specifies the type of data operated on by this <see cref="
ActionBlock
{T}"/>.</typeparam>
24
[DebuggerTypeProxy(typeof(
ActionBlock
<>.DebugView))]
32
/// <summary>Initializes the <see cref="
ActionBlock
{T}"/> with the specified <see cref="System.Action{T}"/>.</summary>
39
/// <summary>Initializes the <see cref="
ActionBlock
{T}"/> with the specified <see cref="System.Action{T}"/> and <see cref="ExecutionDataflowBlockOptions"/>.</summary>
41
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
ActionBlock
{T}"/>.</param>
48
/// <summary>Initializes the <see cref="
ActionBlock
{T}"/> with the specified <see cref="System.Func{T,Task}"/>.</summary>
55
/// <summary>Initializes the <see cref="
ActionBlock
{T}"/> with the specified <see cref="System.Func{T,Task}"/> and <see cref="ExecutionDataflowBlockOptions"/>.</summary>
57
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
ActionBlock
{T}"/>.</param>
64
/// <summary>Initializes the <see cref="
ActionBlock
{T}"/> with the specified delegate and options.</summary>
66
/// <param name="dataflowBlockOptions">The options with which to configure this <see cref="
ActionBlock
{T}"/>.</param>
195
((
ActionBlock
<TInput>)state!).AsyncCompleteProcessMessageWithTask(completed);
268
/// for the item to actually be processed (for example, <see cref="System.Threading.Tasks.Dataflow.
ActionBlock
{T}"/>
326
private readonly
ActionBlock
<TInput> _actionBlock;
334
public DebugView(
ActionBlock
<TInput> actionBlock)