Как ускорить 1С – Многопоточная обработка данных
Периодически возникает необходимость в ускорении некоторых участков кода, в которых при беглом ознакомлении нет потенциала для ускорения.
Рассмотрим в качестве примера выгрузку и/или загрузку большого количества данных.
В данном случае «планкой производительности» зачастую выступает непосредственно производительность аппаратных средств. При этом сами процедуры загрузки-выгрузки выполняются достаточно длительное время, часто измеряемое в часах.
Не все знают, что в платформе «1С: Предприятие 8» часть операций можно выполнять параллельно, путем одновременного выполнения в несколько потоков.
Такая многопоточная обработка вполне применима в случае, когда нужно обработать независимые блоки данных. В частности, создать большой объем элементов данных, осуществить проведение документов, не пересекающихся по значениям набора измерений, сделать массовое обновление элементов справочников, выполнить загрузку данных в регистры и т.д.
Для примера рассмотрим задачу: необходимо провести обновление реквизита «Цена» для всех элементов справочника «Товары». Количество элементов справочника «Товары» равно 100 000.
Самым простым и очевидным решением выступает нижеприведенный код обработки, который быстро пишется, но при этом очень долго работает:
&НаСервере
Процедура ОбновитьЦену()
ВремяНачала = ТекущаяДата();
Запрос = Новый Запрос;
Запрос.Текст =
«ВЫБРАТЬ
| Товары.Ссылка
|ИЗ
| Справочник.Товары КАК Товары»;
ТаблицаТоваров = Запрос.Выполнить().Выгрузить();
Наценка = 1.10;
Для каждого ТекСторока Из ТаблицаТоваров Цикл
ТоварОбъект = ТекСторока.Ссылка.ПолучитьОбъект();
ТоварОбъект.Цена = ТоварОбъект.Цена*Наценка;
ТоварОбъект.Записать();
КонецЦикла;
Длительность = ТекущаяДата()-ВремяНачала;
Сообщить («Длительность: « + Длительность + » сек.»);
КонецПроцедуры
В нашем случае обработка выполнялась 1 187 секунд или 19,7 минуты.
Теперь воспользуемся многопоточным выполнением программного кода. Перепишем код обработки следующим образом:
&НаСервере
Процедура ОбновитьЦену()
ВремяНачала = ТекущаяДата();
Запрос = Новый Запрос;
Запрос.Текст =
«ВЫБРАТЬ
| Товары.Ссылка
|ИЗ
| Справочник.Товары КАК Товары»;
ТаблицаТоваров = Запрос.Выполнить().Выгрузить();
// определяем максимальное количество потоков
ЧислоПотоков = 8;
ЧислоСтрокВТаблице = ТаблицаТоваров.Количество();
// объем порции данных для обработки каждым потоком
РазмерПорции = Цел(ЧислоСтрокаВТаблице/ЧислоПотоков);
// массив, где будут храниться фоновые задания
МассивЗаданий = Новый Массив;
Для НомерПотока = 1 По ЧислоПотоков Цикл
// определяем индекс для начала обработки данных данным потоком
// разные потоки обрабатывают разные части таблицы
ИндексНачала = (НомерПотока - 1)*РазмерПорции;
Если (НомерПотока = ЧислоПотоков) Тогда
// если это последний поток, то он обрабатывает все оставшиеся данные
// т.к. число потоков может не быть кратно количеству строк в таблице
РазмерПорции = ЧислоСтрокВТаблице-(ЧислоПотоков*РазмерПорции)+РазмерПорции;
КонецЕсли;
// определяем массив параметров для процедуры
НаборПараметров = Новый Массив;
НаборПараметров.Добавить(ТаблицаТоваров);
НаборПараметров.Добавить(ИндексНачала);
НаборПараметров.Добавить(РазмерПорции);
// запуск фонового задания
Задание = ФоновыеЗадания.Выполнить(«ОбщийМодуль1.ОбновитьЦенуТовара», НаборПараметров);
// добавляем задание в массив, чтобы потом отследить выполнение
МассивЗаданий.Добавить(Задание);
КонецЦикла;
// проверим результат выполнения фоновых заданий
Если МассивЗаданий.Количество() > 0 Тогда
Попытка
ФоновыеЗадания.ОжидатьЗавершения(МассивЗаданий);
Исключение
// действия в случае ошибки
КонецПопытки;
КонецЕсли;
Длительность = ТекущаяДата()-ВремяНачала;
Сообщить(«Длительность: « + Длительность + «сек.»);
КонецПроцедуры
Код общего модуля:
Процедура ОбновитьЦенуТовара (ТаблицаТоваров, ИндексНачала, РазмерПорции) Экспорт
Наценка = 1.10; // наценка 10%
// обновляем цену только для определенной части таблицы
Для Сч = 1 По РазмерПорции Цикл
Индекс = ?(Сч=1, ИндексНачала, Индекс+1);
ТоварОбъект = ТаблицаТоваров[Индекс].Ссылка.ПолучитьОбъект();
ТоварОбъект.Цена = ТоварОбъект.Цена * Наценка;
ТоварОбъект.Записать();
КонецЦикла;
КонецПроцедуры
-69%