catch没有捕获多线程错误

Question

以下是一个完整的控制台程序,它重现了我遇到的一个奇怪的错误.该程序读取包含远程文件URL的文件,每行一个.它会激活50个线程来下载它们.

static void Main(string[] args)
{
    try
    {
        string filePath = ConfigurationManager.AppSettings["filePath"],
            folder = ConfigurationManager.AppSettings["folder"];
        Directory.CreateDirectory(folder);
        List<string> urls = File.ReadAllLines(filePath).Take(10000).ToList();

        int urlIX = -1;
        Task.WaitAll(Enumerable.Range(0, 50).Select(x => Task.Factory.StartNew(() =>
          {
              while (true)
              {
                  int curUrlIX = Interlocked.Increment(ref urlIX);
                  if (curUrlIX >= urls.Count)
                      break;
                  string url = urls[curUrlIX];
                  try
                  {
                      var req = (HttpWebRequest)WebRequest.Create(url);
                      using (var res = (HttpWebResponse)req.GetResponse())
                      using (var resStream = res.GetResponseStream())
                      using (var fileStream = File.Create(Path.Combine(folder, Guid.NewGuid() + url.Substring(url.LastIndexOf('.')))))
                          resStream.CopyTo(fileStream);
                  }
                  catch (Exception ex)
                  {
                      Console.WriteLine("Error downloading img: " + url + "\n" + ex);
                      continue;
                  }
              }
          })).ToArray());
    }
    catch
    {
        Console.WriteLine("Something bad happened.");
    }
}

在我的本地计算机上它工作正常.在服务器上,下载了几百张图像后,它会显示一个Attempted to read or write protected memory或两个错误Unable to read data from the transport connection: A blocking operation was interrupted by a call to WSACancelBlockingCall..

这似乎是一个原生错误,因为内部和外部捕获都没有捕获它.我从来没有见过Something bad happened..

我把它运行了WinDbg,它显示了以下内容:

(3200.1790): Access violation - code c0000005 (first chance)
First chance exceptions are reported before any exception handling.
This exception may be expected and handled.
LavasoftTcpService64+0x765f:
00000001`8000765f 807a1900        cmp     byte ptr [rdx+19h],0 ds:baadf00d`0000001a=??
0:006> g
(3200.326c): CLR exception - code e0434352 (first chance)
(3200.326c): CLR exception - code e0434352 (first chance)
(3200.2b9c): Access violation - code c0000005 (!!! second chance !!!)
LavasoftTcpService64!WSPStartup+0x9749:
00000001`8002c8b9 f3a4            rep movs byte ptr [rdi],byte ptr [rsi]

我刚刚关闭Lavasoft,现在WinDbg显示了这个:

Critical error detected c0000374
(3c4.3494): Break instruction exception - code 80000003 (first chance)
ntdll!RtlReportCriticalFailure+0x4b:
00007fff`4acf1b2f cc              int     3
0:006> g
(3c4.3494): Unknown exception - code c0000374 (first chance)
(3c4.3494): Unknown exception - code c0000374 (!!! second chance !!!)
ntdll!RtlReportCriticalFailure+0x8c:
00007fff`4acf1b70 eb00            jmp     ntdll!RtlReportCriticalFailure+0x8e (00007fff`4acf1b72)
0:006> g
WARNING: Continuing a non-continuable exception
(3c4.3494): C++ EH exception - code e06d7363 (first chance)
HEAP[VIPJobsTest.exe]: HEAP: Free Heap block 0000007AB96CC5D0 modified at 0000007AB96CC748 after it was freed
(3c4.3494): Break instruction exception - code 80000003 (first chance)
ntdll!RtlpBreakPointHeap+0x1d:
00007fff`4acf3991 cc              int     3

Answer 1

你的例外没有抛出,因为你好,不要试图得到它.WaitAll方法基本上是一个Barrier,等待(哈哈)所有任务完成.它是void,所以你必须为你的任务保存一个参考,以便进行进一步的操作,如下所示:

var tasks = Enumerable.Range(0, 50).Select(x => Task.Factory.StartNew(() =>
{
    while (true)
    {
        // ..
        try
        {
            // ..
        }
        catch (Exception ex)
        {
            // ..
        }
    }
})).ToArray();

Task.WaitAl((tasks);

// investigate exceptions here
var faulted = tasks.Where(t => t.IsFaulted);

根据MSDN,当您使用静态或实例Task.Wait或Task<TResult>.Wait方法或.Result属性之一时,会传播异常.但是,这不是您的选择,因为您在try/catch这里使用.所以你需要订阅TaskScheduler.UnobservedTaskException活动:

TaskScheduler.UnobservedTaskException += TaskScheduler_UnobservedTaskException;

static void TaskScheduler_UnobservedTaskException(object sender, UnobservedTaskExceptionEventArgs e)
{
    Console.WriteLine("Error." + e);
    e.SetObserved();
}

为什么没有扔掉它？

此应用程序域范围事件提供了一种机制,可防止异常升级策略(默认情况下终止进程)触发.

为了使开发人员更容易根据任务编写异步代码,.NET Framework 4.5更改了未观察到的异常的默认异常行为.尽管未观察到的异常仍会引发UnobservedTaskException异常,但默认情况下该进程不会终止.相反,异常是在引发事件后由运行时处理的,无论事件处理程序是否遵循该异常.可以配置此行为.从开始.NET Framework 4.5,您可以使用配置元素恢复到.NET Framework 4的行为并终止该过程:

<configuration> 
 <runtime> 
  <ThrowUnobservedTaskExceptions enabled="true"/> 
 </runtime> 
</configuration>

现在,回到你的代码.考虑使用静态HttpClient实例而不是HttpWebRequest,因为您只需要一个结果字符串.此类旨在用于多线程代码,因此它的方法是线程安全的.

此外,你应该为TaskCreationOptions.LongRunning你的StartNew方法提供一个标志(顺便说一句,这是危险的,但你仍然需要它):

指定任务将是一个长时间运行的粗粒度操作,涉及比细粒度系统更少,更大的组件.它提供了一个提示,TaskScheduler即可能需要超额认购.

Oversubscription允许您创建比可用硬件线程数更多的线程.它还向任务调度程序提供了一个提示,即任务可能需要一个额外的线程,这样它就不会阻止本地线程池队列中其他线程或工作项的前进.

Answer 2

毕竟问题出在 Lavasoft Web Companion 上。即使我禁用了它，它仍然有一些东西在后台运行。卸载它，解决了问题。