具有非异步 lambda 的 Task.Run 异常

Question

我正在查询数据库并将结果包装到视图模型中。测试故意错误的连接字符串，当查询在for (object result in query) 处执行时抛出异常。根据我的研究（如下），应由外部 try/catch 块处理异常，而不添加 async 作为 lambda 的关键字。但是，当我运行没有async 关键字的代码时，没有捕获到异常并且程序崩溃了。

为什么我的异常没有得到处理？

请注意，这里唯一的变化是将 async 添加到 Task.Run 的 lambda 表达式中。

---

According to Stephen Cleary's comment on this answer 外部try/catch 应该在没有async 的情况下捕获异常。

This echoes the first link

I have confirmed that "Break When Thrown" is disabled

---

更新

从评论中，我尝试了Disabling "Just my Code"

它确实允许捕获异常，但它仍然产生异常行为。

如果您在禁用“仅我的代码”的情况下运行 非-async 示例，则会在返回到 catch 块之前抛出异常 15 次。

---

异常未被外部try/catch捕获

using System;
using System.Linq;
using System.Threading.Tasks;
using System.Data.Linq;
using System.Data.Linq.Mapping;

namespace ThisQuestion
{
    class Program
    {
        static void Main(string[] args)
        {
            DoWork();

            Console.ReadLine();
        }


        private async static void DoWork()
        {
            DataContext _db = new DataContext("badconnectionstring");

            Table<Objects> objects = _db.GetTable<Objects>();

            IQueryable<object> query =
                    from o in objects
                    select o;

            try
            {
                await Task.Run
                (() =>
                {
                    foreach (object result in query) ;
                });
            }
            catch (System.Data.SqlClient.SqlException)
            {
                System.Diagnostics.Debug.WriteLine("SQLError");
            }
        }
    }

    [Table(Name="Objects")]
    class Objects
    {
        private string AColumn;
    }
}

---

外部try/catch捕获的异常

using System;
using System.Linq;
using System.Threading.Tasks;
using System.Data.Linq;
using System.Data.Linq.Mapping;

namespace ThisQuestion
{
    class Program
    {
        static void Main(string[] args)
        {
            DoWork();

            Console.ReadLine();
        }


        private async static void DoWork()
        {
            DataContext _db = new DataContext("badconnectionstring");

            Table<Objects> objects = _db.GetTable<Objects>();

            IQueryable<object> query =
                    from o in objects
                    select o;

            try
            {
                await Task.Run
                (async () =>
                {
                    foreach (object result in query) ;
                });
            }
            catch (System.Data.SqlClient.SqlException)
            {
                System.Diagnostics.Debug.WriteLine("SQLError");
            }
        }
    }

    [Table(Name="Objects")]
    class Objects
    {
        private string AColumn;
    }
}

---

“只是我的代码”已禁用

---

已启用“仅我的代码”，不支持 async

---

启用“仅我的代码”，async

Answer 1

异常仍然没有被正确处理

我不认为这是一个正确的说法。

在两个版本的代码中，您的catch (System.Data.SqlClient.SqlException) 语句都会捕获异常。这怎么不“正确”？

您看到差异的唯一原因是 调试器 的行为方式。在第二个示例中，调试器不报告异常，因为就它而言，正在处理异常。异步 lambda 返回的 Task 对象可以观察到这一点（注意在这种情况下会调用 Task.Run(Func<Task>) 重载）。

在第一个代码示例中，Run() 方法正在执行直接的Action lambda。在这种情况下，发生异常的线程中没有Task对象；原来的线程中只有一个你叫Task.Run()。因此，就调试器而言，异常在发生的那个线程中未处理。

因此，在第一个示例中，根据调试器的规则，异常未处理。当然，它仍然被观察到。 Task.Run()返回的Task对象封装了异常，你可以通过等待Task对象来观察它。

在第二个例子中，根据调试器的规则，异常被处理。在它发生的同一线程中，由您的异步 lambda 返回的 Task 对象观察到。调试器对此很好，不会通知您。

但在这两个示例中，代码 的基本行为是相同的。您的任务抛出异常，并通过等待 Task.Run() 返回的 Task 对象被捕获在原始线程中（因为在任何一种情况下，异常都会传播到 Task 对象，只是通过不同的机制）。

注意：以上内容仅适用于您提供的两个完整代码示例。您在您的问题中有关于“15 个例外”等的额外讨论，我无法解决这些问题，因为没有 MCVE 可以重现该行为。但是假设您在两个完整的代码示例中正确地表示了基本问题，上述内容将适用于您所询问的更广泛的场景。