不遵守链接的 ActionBlock 的 BoundedCapacity

问题描述

我有一个由两个步骤组成的顺序管道。

（简化示例）

第一步只是将 1000 添加到输入数字上。 第二步只是显示数字。

var transformBlock = new TransformBlock<int,long>(StepOne,new ExecutionDataflowBlockOptions
{
      MaxDegreeOfParallelism = 1,BoundedCapacity = DataflowBlockOptions.Unbounded,});
var actionBlock = new ActionBlock<long>(StepTwo,BoundedCapacity = 2,});
transformBlock.LinkTo(actionBlock,new DataflowLinkOptions
{
    PropagateCompletion = true
});

for (int i = 0; i < 100; i++)
{
    transformBlock.Post(i);
}

static async Task<long> StepOne(int item)
{
    await Task.Delay(500);
    Console.WriteLine("transforming: " + item);
    return (long)item + 1000;
}

static async Task StepTwo(long item)
{
    await Task.Delay(1000);
    Console.WriteLine("final product: " + item);
}

由于第 2 步比第 1 步花费的时间长，我希望第 1 步会在一段时间后节流，因为它无法将结果发送到第 2 步的有界缓冲区。

预期输出：
变形：0
变形：1
最终产品：1000
变形：2
最终产品：1001
变形：3
最终产品：1002
变形：4
最终产品：1003
...

实际输出：
变形：0
变形：1
最终产品：1000
变形：2
变形：3
最终产品：1001
变形：4
变形：5
最终产品：1002
变形：6
变形：7
最终产品：1003
...

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）