Завершение потока данных TPL с не работающим MaxMessage - опция не работает - PullRequest
Новая
       56

Завершение потока данных TPL с не работающим MaxMessage - опция не работает

0 голосов
/ 22 января 2019

Я уже проверил этот пост: C # TPL Dataflow - Завершение не работает (но добавление нулевой цели не изменит здесь результата)

и еще несколько.

Однако я не понимаю, почему этот пример не завершается: 

private static async Task WriteIntDelayed(int delay_ms, string name, int? i)
{
    await Task.Delay(delay_ms);
    await Console.Out.WriteLineAsync(name + "\t" + (i.HasValue ? i.ToString() : "null"));
}
private static int counter = 0;
public static async Task ExecuteMultipleSuccessorsSampleAsync()
{
    TransformBlock<string, int?> tb = new TransformBlock<string, int?>(
                s =>
                {
                    if (Int32.TryParse(s, out int result))
                    {
                        return result;
                    }
                    else
                        return null;
                });

    ActionBlock<int?> ab1 = new ActionBlock<int?>(async (int? i) => await WriteIntDelayed(10, $"ab1[{counter++}]", i));
    ActionBlock<int?> ab2 = new ActionBlock<int?>(
        async (int? i)
            => await WriteIntDelayed(500, $"ab2[{counter++}]", i)
        , new ExecutionDataflowBlockOptions { BoundedCapacity = 1 });
    ActionBlock<int?> ab3 = new ActionBlock<int?>(
        async (int? i)
            => await WriteIntDelayed(200, $"ab3[{counter++}]", i),
        new ExecutionDataflowBlockOptions { BoundedCapacity = 1 });

    tb.LinkTo(ab1, new DataflowLinkOptions { MaxMessages = 10, PropagateCompletion = true });
    tb.LinkTo(ab2, new DataflowLinkOptions { PropagateCompletion = true });
    tb.LinkTo(ab3, new DataflowLinkOptions { PropagateCompletion = true });


    // Parallel.For(0, 30, (i, state) =>
    // {
    //     tb.Post(i.ToString());
    // });

    for (int i = 0; i < 30; i++)
    {
        tb.Post(i.ToString());
    }

    tb.Complete();
    await Task.WhenAll(
        ab1.Completion /*will NOT complete */, 
        ab2.Completion /*will complete */, 
        ab3.Completion /*will complete */);
}
...