Windows 服务、blockingcollection 和多线程的问题

Question

我的场景：

• Windows 服务 .NET 4
• 我在数据库中轮询实体。
• 当新实体进入时，它们会被添加到BlockingCollection。
• 在服务的OnStart 中，我创建了一个System.Threading.Tasks.Task，其工作是枚举BlockingCollection（使用GetConsumingEnumerable()）。

我遇到的问题是这样的：

• 当任务中发生未处理的异常时，我希望记录异常并停止服务。
• 除非我调用Task.Wait()，否则我无法从任务中捕获异常。
• 如果我调用Task.Wait() OnStart 方法阻塞并且服务永远不会完成启动。

那么我怎样才能做到这一点呢？

Answer 1

您可以使用 `.ContinueWith' 方法处理任务中的异常：

Task.Factory.StartNew(() => {

    // Do some long action
    Thread.SpinWait(5000000);

    // that eventually has an error :-(
    throw new Exception("Something really bad happened in the task.");

    // I'm not sure how much `TaskCreationOptions.LongRunning` helps, but it sounds 
    // like it makes sense to use it in your situation.
}, TaskCreationOptions.LongRunning).ContinueWith(task => {

    var exception = task.Exception;

    /* Log the exception */

}, TaskContinuationOptions.OnlyOnFaulted); // Only run the continuation if there was an error in the original task.