stop Параллельный.ForEach немедленно

Question

У меня есть проблема с остановкой параллели для каждого цикла.

Я повторяю набор из около 40.000 DataRows, извлеченных из таблицы, и мне нужно немедленно остановить цикл, когда у меня есть 100 элементов в моем наборе результатов. Проблема в том, что когда я запускаю метод Stop на ParallelLoopState, итерация не останавливается немедленно, вызывая несогласованность в моем наборе результатов (либо до нескольких, либо ко многим элементам).

Нет ли способа убедиться, что я убью все потоки, как только я нажму стоп?

List<DataRow> rows = new List<DataRow>(dataTable.Select()); 
    ConcurrentDictionary<string, object> resultSet = new ConcurrentDictionary<string, object>(); 

    rows.EachParallel(delegate (DataRow row, ParallelLoopState state) 
    { 
    if (!state.IsStopped) 
    { 
     using (SqlConnection sqlConnection = new SqlConnection(Global.ConnStr)) 
     { 
     sqlConnection.Open(); 

     //{ 
     // Do some processing....... 
     //}  

     var sourceKey = "key retrieved from processing"; 
     if (!resultSet.ContainsKey(sourceKey)) 
     { 
      object myCustomObj = new object(); 

      resultSet.AddOrUpdate(
      sourceKey, 
      myCustomObj, 
      (key, oldValue) => myCustomObj); 
     } 

     if (resultSet.Values.Count == 100) 
      state.Stop(); 
     } 
    } 
    }); 

Answer 1

Документация страница ParallelLoopState.Stop объясняет, что вызов Stop() будет предотвратить новые итерации от начала. Он не отменяет никаких существующих итераций.

Stop() также устанавливает IsStopped на true. Длинные итерации могут проверять значение IsStopped и, если необходимо, выйти преждевременно.

Это называется совместное аннулирование, которое намного лучше, чем прерывание потоков. Прерывание потока дорогое и затрудняет очистку. Представьте, что произойдет, если исключение ThreadAbort было брошено только тогда, когда вы хотели совершить свою работу.

Cooperative отмена с другой стороны, позволяет задачу выйти грациозно после или прерывания совершала сделки по мере необходимости, закрытие соединения, уборки другого состояния и файлов и т.д.

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

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