数据流(TPL)——异常处理问题

本文关键字：异常 处理问题 TPL 数据流 | 更新日期: 2023-09-27 18:14:41

我不确定我是否做错了什么，或者这是一个问题与数据流，但我不能工作时接收()抛出异常。当我运行这个测试时:

public class AsyncProblem
{
    [Fact]
    public void AsyncVsAwaiterProblem()
    {
        var max = 1000;
        var noOfExceptions = 0;
        for (int i = 0; i < max; i++)
        {
            try
            {
                Await().Wait();
            }
            catch
            {
                noOfExceptions++;
            }
        }
        Assert.Equal(max,noOfExceptions);
    }
    public async Task Await()
    {
        bool firstPassed = false;
        var divideBlock = new TransformBlock<int, int>((x) =>
        {
            if (firstPassed)
                throw new ArgumentException("error");
            firstPassed = true;
            return 0;
        });
        divideBlock.Post(2);
        divideBlock.Post(3); // this should cause failure;
        divideBlock.Complete();
        while (await divideBlock.OutputAvailableAsync())
        {
                var value = divideBlock.Receive(); // this should throw exception on second call
        }
        try
        {
            divideBlock.Completion.Wait();
        }
        catch
        {
        }
    }
}

我得到不一致的结果，第一次运行:

Xunit.Sdk.EqualExceptionAssert.Equal() Failure 
Expected: 1000 
Actual:  127

然后再运行:

Xunit.Sdk.EqualExceptionAssert.Equal() Failure
Expected: 1000
Actual:   14

有人能确认这不是"在我的机器上"的问题吗?

要点:https://gist.github.com/plentysmart/1c2ed2e925cc3f690f61

数据流(TPL)——异常处理问题

实际上，我认为混乱是由于OutputAvailableAsync的行为。当再也没有输出时，该方法将返回false。

当一个块出错时(即，作为来自转换委托的异常的结果)，它将清除输入和输出缓冲区。这导致OutputAvailableAsync返回false。

相关文章：