Распараллеливание обработки массива

@tryff · Регистрация: 19.12.2015

Студворк — интернет-сервис помощи студентам

Привел код для примера (реальный посерьезней).
Надо обрабатывать массив в несколько потоков и иметь возможность в любой момент эту обработку прервать.

C#
1
2
3
4
5
6
7
event EventHandler Loaded;
 
public void LoadImages(DirectoryInfo source)
{
    foreach (var file in source.GetFiles())
            Loaded?.Invoke( new Icon(file) );
}

Пытался сделать через Parallel и PLINQ.
Столкнулся с проблемой полного зависания обработки на определенном элементе (без генерации события работает).

C#
1
2
3
4
5
6
event EventHandler Loaded;
 
public void LoadImages(DirectoryInfo source)
{
        Parallel.ForEach(source.GetFiles(), (arg) => Loaded?.Invoke( new Icon(arg) ));
}

Также делал через ThreadPool - работает. Но возможности отмены нет.

@kolorotur · 08.02.2016, 19:28

Замените Invoke на BeginInvoke.

@tryff · 08.02.2016, 21:46 **[ТС]**

Хорошо бы понять почему с Invoke зависает, а с BeginInvoke нет

@kolorotur · 08.02.2016, 22:47

Сообщение от tryff

Хорошо бы понять почему с Invoke зависает, а с BeginInvoke нет

Вызов Parallel.ForEach замораживает поток до тех пор, пока весь цикл не выполнится.
Этот метод вы вызываете, скорее всего, в основном потоке.
Метод Invoke выполняет передаваемый ему делегат в основном потоке и замораживает текущий до тех пор, пока этот делегат не отработает.
Получается классический deadlock: основной поток ждет завершения работы Parallel.ForEach, а Invoke внутри ForEach ждет возможности выполнить код в основном потоке.

BeginInvoke же просто добавляет делегат в очередь на выполнение и не ждет окончания его работы, а возвращает управление вызывающему методу сразу.

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

Новые блоги и статьи Все статьи Все блоги /
Настройки VS Code Loafer 13.04.2026 { "cmake. configureOnOpen": false, "diffEditor. ignoreTrimWhitespace": true, "editor. guides. bracketPairs": "active", "extensions. ignoreRecommendations": true, . . .	Оптимизация кода на разграничение прав доступа к элементам формы Maks 13.04.2026 Алгоритм из решения ниже реализован на нетиповом документе, разработанного в конфигурации КА2. Задачи, как таковой, поставлено не было, проделанное ниже исключительно моя инициатива. Было так:. . .	Контроль заполнения и очистка дат в зависимости от значения перечислений Maks 12.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .	Архитектура слоя интернета для сервера-слоя. Hrethgir 11.04.2026 В продолжение https:/ / www. cyberforum. ru/ blogs/ 223907/ 10860. html Знаешь что я подумал? Раз мы все источники пишем в голове ветки, то ничего не мешает добавить в голову такой источник, который сам. . .
Подстановка значения реквизита справочника в табличную часть документа Maks 10.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: при выборе сотрудника (справочник Сотрудники) в ТЧ документа. . .	Очистка реквизитов документа при копировании Maks 09.04.2026 Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .	модель ЗдравоСохранения 8. Подготовка к разному выполнению заданий anaschu 08.04.2026 https:/ / github. com/ shumilovas/ med2. git main ветка * содержимое блока дэлэй из старой модели теперь внутри зайца новой модели 8ATzM_2aurI	Блокировка документа от изменений, если он открыт у другого пользователя Maks 08.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в конфигурации КА2. Задача: запретить редактирование документа, если он открыт у другого пользователя. / / . . .

@kolorotur 17823 / 12973 / 3382 Регистрация: 17.09.2011 Сообщений: 21,261
	08.02.2016, 19:28
	Сообщение было отмечено tryff как решение Решение Замените Invoke на BeginInvoke. 1

@tryff 0 / 0 / 1 Регистрация: 19.12.2015 Сообщений: 21
	08.02.2016, 21:46 [ТС]
	Хорошо бы понять почему с Invoke зависает, а с BeginInvoke нет 0

Распараллеливание обработки массива

Решение