时间戳

首页 > 解决方案 > TPL 数据流：为什么会出现以下阻塞？

c# - TPL 数据流：为什么会出现以下阻塞？

问题描述

为什么调用Run()阻塞而不返回？

它正确地打印以下输出，这是有道理的。因为我已经初始化了BatchBlock()170 的大小并创建了 200 个 volapoint 对象。但为什么它不返回？

ConvertToVolaSurface 
ConvertToVolaSurface 
CalculateStrangles
CalculateStrangles

这是我正在使用的代码片段

class Pipeline
{
    public void Run()
    {
        // Grouping block - Collect vola points until vola surface is full 
        var batchBlock1 = new BatchBlock<VolaPoint>(170);

        // Execution block - Convert vola points to surface
        var transformBlock0 = new TransformBlock<VolaPoint[], VolaSurface>(x => this.ConvertToVolaSurface(x));

        // Execution block - Calculate strangles 
        var transformBlock1 = new TransformBlock<VolaSurface, VolaSurface>(x => this.CalculateStrangles(x));

        var linkOptions = new DataflowLinkOptions()
        {
            PropagateCompletion = true
        };

        batchBlock1.LinkTo(transformBlock0, linkOptions);
        transformBlock0.LinkTo(transformBlock1, linkOptions);

        for (int i = 0; i <= 200; i++)
        {
            batchBlock1.Post(new VolaPoint());
        }

        batchBlock1.Complete();

        transformBlock1.Completion.Wait();
    }

    private VolaSurface ConvertToVolaSurface(VolaPoint[] volapoints)
    {
        Debug.WriteLine("ConvertToVolaSurface");

        return new VolaSurface();
    }

    private VolaSurface CalculateStrangles(VolaSurface volaSurface)
    {
        Debug.WriteLine("CalculateStrangles");

        return volaSurface;
    }
}

标签： c#task-parallel-librarytpl-dataflow

解决方案

你的最后一个块是一个TransformBlock，转换块有一个输出缓冲区，它们必须为空Complete。将您的最后一个块更改为 anActionBlock并且await不阻塞调用线程就完成了。

public async Task Run()
{
    // Grouping block - Collect vola points until vola surface is full 
    var batchBlock1 = new BatchBlock<VolaPoint>(170);

    // Execution block - Convert vola points to surface
    var transformBlock0 = new TransformBlock<VolaPoint[], VolaSurface>(x => this.ConvertToVolaSurface(x));

    // Execution block - Calculate strangles 
    var actionBlock1 = new ActionBlock<VolaSurface>(x => this.CalculateStrangles(x));

    var linkOptions = new DataflowLinkOptions()
    {
        PropagateCompletion = true
    };

    batchBlock1.LinkTo(transformBlock0, linkOptions);
    transformBlock0.LinkTo(actionBlock1, linkOptions);

    for (int i = 0; i <= 200; i++)
    {
        batchBlock1.Post(new VolaPoint());
    }

    batchBlock1.Complete();

    await actionBlock1.Completion;
}

现在，如果CalculateStrangles(x)正在返回某些东西，那么您需要将最后一个转换块链接到其他东西，否则您将永远无法完成。

推荐阅读