Многопоточная ошибка, не попавшая в ловушку

Ответ 1

В конце концов, проблема была в Lavasoft Web Companion. Несмотря на то, что я отключил его, все еще было что-то от него, работающее на заднем плане. Удалив его, исправлена ​​проблема.

Ответ 2

Ваше исключение не бросается, потому что вы, ну, не пытаетесь его получить. WaitAll метод - это в основном Barrier, который ждет (haha) для завершения всех задач. Это 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 (который опасен, кстати, но он вам еще нужен):

Указывает, что задача будет длительной, крупнозернистой операцией, включающей менее крупные компоненты, чем мелкозернистые системы. Он дает подсказку TaskScheduler, что может потребоваться превышение подписки.

Oversubscription позволяет создавать больше потоков, чем доступное количество аппаратных потоков. Он также дает подсказку планировщику задач, что для задачи может потребоваться дополнительный поток, чтобы он не блокировал продвижение вперед других потоков или рабочих элементов в локальной очереди пулов потоков.

Ответ 3

Вы можете добавить продолжение в свою задачу.

 Task.Factory.StartNew(() => ...)
    .ContinueWith (task => 
    {
       If (task.isFaulted)
       {
           //task.Exception
           //handle the exception from this context
       }
    });

Ответ 4

В вашем примере есть код, который фактически не защищен try/catch. Ошибка в том, что в потоке было бы исключено неперехваченное исключение.

Вот рефактор (комментарии по ранее незащищенному коду). Внешняя попытка не поймает их, как в исходной нити. Поэтому он будет необработанным на подписях

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(() =>
          {
              try
              {
                  while (true) // ** was unprotected
                  {
                      int curUrlIX = Interlocked.Increment(ref urlIX);  // ** was unprotected
                      if (curUrlIX >= urls.Count)   // ** was unprotected
                          break;                    // ** was unprotected
                      string url = urls[curUrlIX];  // ** was unprotected
                      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;
                      }
                  } // while
              } // try
          })).ToArray());
    }
    catch
    {
        Console.WriteLine("Something bad happened.");
    }
}