在 TPL 中，如果 Task 抛出异常, 该异常被捕获并存储在 Task.Exception 中, 然后遵循 observed exceptions 上的所有规则.如果它从未被观察到，它最终会在终结器线程上重新抛出并使进程崩溃。

有没有办法阻止 Task 捕获该异常，而只是让它传播？

我感兴趣的任务已经在 UI 线程上运行(由 TaskScheduler.FromCurrentSynchronizationContext 提供)，我希望异常转义以便它可以由我现有的 Application.ThreadException 处理处理程序。

我基本上希望 Task 中未处理的异常表现得像按钮单击处理程序中的未处理异常:立即在 UI 线程上传播，并由 ThreadException 处理。

最佳答案

好的，Joe...正如所 promise 的，这里是您如何使用自定义 TaskScheduler 子类来解决这个问题。我已经测试了这个实现，它就像一个魅力。 不要忘记如果你想看到 Application.ThreadException 实际触发，你就不能附加调试器!!!

自定义任务调度器

这个自定义的 TaskScheduler 实现在“诞生”时绑定(bind)到特定的 SynchronizationContext 并将接收它需要执行的每个传入 Task，将一个 Continuation 链接到它上面仅当逻辑 Task 出错时才会触发，当它触发时，它会 Post 返回到 SynchronizationContext，它会从 Task 中抛出异常> 那是错误的。

public sealed class SynchronizationContextFaultPropagatingTaskScheduler : TaskScheduler
{
    #region Fields

    private SynchronizationContext synchronizationContext;
    private ConcurrentQueue<Task> taskQueue = new ConcurrentQueue<Task>();

    #endregion

    #region Constructors

    public SynchronizationContextFaultPropagatingTaskScheduler() : this(SynchronizationContext.Current)
    {
    }

    public SynchronizationContextFaultPropagatingTaskScheduler(SynchronizationContext synchronizationContext)
    {
        this.synchronizationContext = synchronizationContext;
    }

    #endregion

    #region Base class overrides

    protected override void QueueTask(Task task)
    {
        // Add a continuation to the task that will only execute if faulted and then post the exception back to the synchronization context
        task.ContinueWith(antecedent =>
            {
                this.synchronizationContext.Post(sendState =>
                {
                    throw (Exception)sendState;
                },
                antecedent.Exception);
            },
            TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.ExecuteSynchronously);

        // Enqueue this task
        this.taskQueue.Enqueue(task);

        // Make sure we're processing all queued tasks
        this.EnsureTasksAreBeingExecuted();
    }

    protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)
    {
        // Excercise for the reader
        return false;
    }

    protected override IEnumerable<Task> GetScheduledTasks()
    {
        return this.taskQueue.ToArray();
    }

    #endregion

    #region Helper methods

    private void EnsureTasksAreBeingExecuted()
    {
        // Check if there's actually any tasks left at this point as it may have already been picked up by a previously executing thread pool thread (avoids queueing something up to the thread pool that will do nothing)
        if(this.taskQueue.Count > 0)
        {
            ThreadPool.UnsafeQueueUserWorkItem(_ =>
            {
                Task nextTask;

                // This thread pool thread will be used to drain the queue for as long as there are tasks in it
                while(this.taskQueue.TryDequeue(out nextTask))
                {
                    base.TryExecuteTask(nextTask);
                }
            },
            null);
        }
    }

    #endregion
}

关于此实现的一些说明/免责声明:

• 如果您使用无参数构造函数，它将获取当前的 SynchronizationContext...因此，如果您只是在 WinForms 线程(主窗体构造函数等)上构造它，它将自动运行。奖励，我还有一个构造函数，您可以在其中显式传递从其他地方获得的 SynchronizationContext。
• 我没有提供 TryExecuteTaskInline 的实现，因此该实现将始终只是将要处理的 Task 排队。我将此作为练习留给读者。这并不难，只是...没有必要展示您要求的功能。
• 我正在使用一种简单/原始的方法来安排/执行利用线程池的任务。肯定会有更丰富的实现，但是这个实现的重点还是简单地将异常编码回“应用程序”线程

好的，现在您有几个使用此 TaskScheduler 的选项:

预配置 TaskFactory 实例

这种方法允许您设置一次 TaskFactory，然后您从该工厂实例开始的任何任务都将使用自定义 TaskScheduler。这基本上看起来像这样:

在应用程序启动时

private static readonly TaskFactory MyTaskFactory = new TaskFactory(new SynchronizationContextFaultPropagatingTaskScheduler());

整个代码

MyTaskFactory.StartNew(_ =>
{
    // ... task impl here ...
});

显式 TaskScheduler 每次调用

另一种方法是创建自定义 TaskScheduler 实例，然后在每次启动时将其传递到默认 TaskFactory 上的 StartNew一项任务。

在应用程序启动时

private static readonly SynchronizationContextFaultPropagatingTaskScheduler MyFaultPropagatingTaskScheduler = new SynchronizationContextFaultPropagatingTaskScheduler();

整个代码

Task.Factory.StartNew(_ =>
{
    // ... task impl here ...
},
CancellationToken.None // your specific cancellationtoken here (if any)
TaskCreationOptions.None, // your proper options here
MyFaultPropagatingTaskScheduler);

关于c# - 如何让任务异常传播回 UI 线程？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/8540529/