В данной статье рассмотрим примеры выполнения функций и процедур в многопоточном режиме, используя возможности Библиотеки стандартных подсистем.
Введение
В этой статье решил привести небольшой программный эксперимент - позапускать собственную процедуру общего модуля конфигурации в многопоточном режиме, используя относительно новые методы библиотеки стандартных подсистем - набора модулей ДлительныеОперации. Разработку примеров я буду вести на типовой конфигурации БСП - версии 3.1.7 на Платформе 1с 8.3.20.
Статью разобью на две части - первая часть описывает процедуру, которая должна будет запускаться многопоточно, вторая - практическое использование запуска в несколько потоков - ВыполнитьПроцедуруВНесколькоПотоков.
Напишем процедуру, которая будет использоваться в многопоточном запуске
В собственном общем модуле конфигурации (я работаю на типовой БСП 3.1.7), создаем искусственную процедуру, которую будем использовать в многопоточном запуске. Выглядит она пусть так:
&НаСервере
Процедура ПроцедураМногопоток(Поток, Параметры) Экспорт
КоличествоСозданныхОбъектов = 0;
Если Параметры.ТипОбработки = "Вариант 1" Тогда // Создадим 500 документов поступления (можно и загрузить)
Для Счетчик = 1 по 500 Цикл
НовДок = Документы._ДемоПоступлениеТоваров.СоздатьДокумент();
НовДок.Дата = ТекущаяДата();
НовДок.Организация = Параметры.Организация;
НовДок.Валюта = Справочники.Валюты.НайтиПоКоду("643");
НовДок.Комментарий = Параметры.КомментарийДокумента;
Попытка
НовДок.Записать(РежимЗаписиДокумента.Запись);
Исключение
КонецПопытки;
КоличествоСозданныхОбъектов = КоличествоСозданныхОбъектов + 1;
КонецЦикла;
ИначеЕсли Параметры.ТипОбработки = "Вариант 2" Тогда // Создадим 1000 записей справочника "Номенклатура"
Для Счетчик = 1 по 1000 Цикл
НовСпр = Справочники._ДемоНоменклатура.СоздатьЭлемент();
НовСпр.Наименование = "Новая номенклатура_"+Строка(Счетчик);
НовСпр.НаименованиеДляПечати = "Новая номенклатура_"+Строка(Параметры.ОписаниеСправочника);
НовСпр.Записать();
КонецЦикла;
КоличествоСозданныхОбъектов = КоличествоСозданныхОбъектов + 1;
КонецЕсли;
КонецПроцедурыПри первом типе обработке - "Вариант 1", процедура - будет создать 500 документов. При втором типе - "Вариант 2" - запустим цикл по созданию 1000 элементов справочника "Номенклатура".
Теперь, перейдем к коду обработки, использующим ДлительныеОперации, запускающим ж
Описание функционала запуска с помощью функции "ВыполнитьПроцедуруВНесколькоПотоков"
Для начала нарисуем вот такую форму:
Напишем процедуру клиентского запуска. Выглядит она вот так:
&НаКлиенте
Процедура ЗапуститьМногопоток(Команда)
ОповещениеОПрогрессеВыполнения = Новый ОписаниеОповещения("ПрогрессВыполнения", ЭтотОбъект);
Задание = СоздадимПотокиНаСервере(УникальныйИдентификатор);
ИдентификаторЗадания = Задание.ИдентификаторЗадания;
НастройкиОжидания = ДлительныеОперацииКлиент.ПараметрыОжидания(ЭтотОбъект);
НастройкиОжидания.ВыводитьОкноОжидания = Ложь;
НастройкиОжидания.ОповещениеОПрогрессеВыполнения = ОповещениеОПрогрессеВыполнения;
НастройкиОжидания.ВыводитьПрогрессВыполнения = Истина;
Обработчик = Новый ОписаниеОповещения("ОбработатьДанные", ЭтотОбъект);
ДлительныеОперацииКлиент.ОжидатьЗавершение(Задание, Обработчик, НастройкиОжидания);
КонецПроцедурыДалее, функция СоздадимПотокиНаСервере(УИД)
&НаСервере
Функция СоздадимПотокиНаСервере(УникальныйИдентификатор)
ПараметрыВыполнения = ДлительныеОперации.ПараметрыВыполненияВФоне(УникальныйИдентификатор);
ПараметрыВыполнения.НаименованиеФоновогоЗадания = НСтр("ru = 'Выполнение многопоточной функции'");
ПараметрыВыполнения.ЗапуститьВФоне = Истина;
ПараметрыМетода = Новый Соответствие();
// ===== первый поток выполнения =====
КодПотока = "Поток 1";
ПараметрыПотока = ПараметрыМногопоточнойФункции();
ПараметрыПотока.ТипОбработки = "Вариант 1";
ПараметрыПотока.ОписаниеСправочника = Объект.ОписаниеСправочника;
ПараметрыПотока.КомментарийДокумента = Объект.КомментарийДокумента;
ПараметрыПотока.Организация = Объект.Организация;
ПараметрыВызоваСервера = Новый Массив;
ПараметрыВызоваСервера.Добавить(КодПотока); // КодПотока
ПараметрыВызоваСервера.Добавить(ПараметрыПотока); // Параметры функции в потоке
ПараметрыМетода.Вставить(КодПотока,ПараметрыВызоваСервера);
// ===== второй поток выполнения =====
КодПотока = "Поток 2";
ПараметрыПотока = ПараметрыМногопоточнойФункции();
ПараметрыПотока.ТипОбработки = "Вариант 2";
ПараметрыПотока.ОписаниеСправочника = Объект.ОписаниеСправочника;
ПараметрыПотока.КомментарийДокумента = Объект.КомментарийДокумента;
ПараметрыПотока.Организация = Объект.Организация;
ПараметрыВызоваСервера = Новый Массив;
ПараметрыВызоваСервера.Добавить(КодПотока); // КодПотока
ПараметрыВызоваСервера.Добавить(ПараметрыПотока); // Параметры функции в потоке
ПараметрыМетода.Вставить(КодПотока,ПараметрыВызоваСервера);
// ===================================
ИмяФункцииИлиПроцедуры = "ОбщийМодуль1.ПроцедураМногопоток";
ФоновоеЗадание = ДлительныеОперации.ВыполнитьПроцедуруВНесколькоПотоков(ИмяФункцииИлиПроцедуры, ПараметрыВыполнения, ПараметрыМетода);
Если ФоновоеЗадание.Статус = "Ошибка" Тогда
Сообщить(СокрЛП(ФоновоеЗадание.Статус));
КонецЕсли;
Возврат ФоновоеЗадание;
КонецФункции
&НаСервере
Функция ПараметрыМногопоточнойФункции()
Результат = Новый Структура();
Результат.Вставить("ТипОбработки", 0);
Результат.Вставить("ОписаниеСправочника", "");
Результат.Вставить("КомментарийДокумента", "");
Результат.Вставить("Организация", Справочники._ДемоОрганизации.ПустаяСсылка());
Результат.Вставить("ЗагружатьПорциями", Истина);
Возврат Результат;
КонецФункцииЗдесь, я обозначаю условные параметры для двух потоков "Поток 1" и "Поток 2". Далее, использую Функцию "ВыполнитьПроцедуруВНесколькоПотоков" с этими параметрами.
Опишем функции "ПрогрессВыполнения" и "ОбработатьДанные" (это будут чисто-условные "полупустые" функции)
&НаКлиенте
Процедура ПрогрессВыполнения(Результат, ДополнительныеПараметры) Экспорт
КонецПроцедуры
&НаСервереБезКонтекста
Функция ПрочитатьПрогресс(ИдентификаторЗадания)
Возврат ДлительныеОперации.ПрочитатьПрогресс(ИдентификаторЗадания);
КонецФункции
&НаКлиенте
Процедура ОбработатьДанные(Задание, ДополнительныеПараметры) Экспорт
Если Задание = Неопределено Тогда
Возврат;
КонецЕсли;
ЭтаФорма.РезультатВыполнения = СокрЛП(Задание.Статус) +" "+СокрЛП(ПолучитьИЗВременногоХранилища(Задание.АдресРезультата));
КонецПроцедурыВесь код модуля формы обработки вот такой (можно скопипастить):
&НаСервере
Функция ПараметрыМногопоточнойФункции()
Результат = Новый Структура();
Результат.Вставить("ТипОбработки", 0);
Результат.Вставить("ОписаниеСправочника", "");
Результат.Вставить("КомментарийДокумента", "");
Результат.Вставить("Организация", Справочники._ДемоОрганизации.ПустаяСсылка());
Результат.Вставить("ЗагружатьПорциями", Истина);
Возврат Результат;
КонецФункции
&НаКлиенте
Процедура ЗапуститьМногопоток(Команда)
ОповещениеОПрогрессеВыполнения = Новый ОписаниеОповещения("ПрогрессВыполнения", ЭтотОбъект);
Задание = СоздадимПотокиНаСервере(УникальныйИдентификатор);
//ИдентификаторЗадания = ПолучитьИЗВременногоХранилища(Задание.АдресРезультата).Получить("Поток 1").ИдентификаторЗадания;//Задание.ИдентификаторЗадания;
ИдентификаторЗадания = Задание.ИдентификаторЗадания;
//Сообщить(ИдентификаторЗадания);
НастройкиОжидания = ДлительныеОперацииКлиент.ПараметрыОжидания(ЭтотОбъект);
НастройкиОжидания.ВыводитьОкноОжидания = Ложь;
НастройкиОжидания.ОповещениеОПрогрессеВыполнения = ОповещениеОПрогрессеВыполнения;
НастройкиОжидания.ВыводитьПрогрессВыполнения = Истина;
Обработчик = Новый ОписаниеОповещения("ОбработатьДанные", ЭтотОбъект);
ДлительныеОперацииКлиент.ОжидатьЗавершение(Задание, Обработчик, НастройкиОжидания);
КонецПроцедуры
&НаСервере
Функция СоздадимПотокиНаСервере(УникальныйИдентификатор)
ПараметрыВыполнения = ДлительныеОперации.ПараметрыВыполненияВФоне(УникальныйИдентификатор);
ПараметрыВыполнения.НаименованиеФоновогоЗадания = НСтр("ru = 'Выполнение многопоточной функции'");
ПараметрыВыполнения.ЗапуститьВФоне = Истина;
ПараметрыМетода = Новый Соответствие();
// ===== первый поток выполнения =====
КодПотока = "Поток 1";
ПараметрыПотока = ПараметрыМногопоточнойФункции();
ПараметрыПотока.ТипОбработки = "Вариант 1";
ПараметрыПотока.ОписаниеСправочника = Объект.ОписаниеСправочника;
ПараметрыПотока.КомментарийДокумента = Объект.КомментарийДокумента;
ПараметрыПотока.Организация = Объект.Организация;
ПараметрыВызоваСервера = Новый Массив;
ПараметрыВызоваСервера.Добавить(КодПотока); // КодПотока
ПараметрыВызоваСервера.Добавить(ПараметрыПотока); // Параметры функции в потоке
ПараметрыМетода.Вставить(КодПотока,ПараметрыВызоваСервера);
// ===== второй поток выполнения =====
КодПотока = "Поток 2";
ПараметрыПотока = ПараметрыМногопоточнойФункции();
ПараметрыПотока.ТипОбработки = "Вариант 2";
ПараметрыПотока.ОписаниеСправочника = Объект.ОписаниеСправочника;
ПараметрыПотока.КомментарийДокумента = Объект.КомментарийДокумента;
ПараметрыПотока.Организация = Объект.Организация;
ПараметрыВызоваСервера = Новый Массив;
ПараметрыВызоваСервера.Добавить(КодПотока); // КодПотока
ПараметрыВызоваСервера.Добавить(ПараметрыПотока); // Параметры функции в потоке
ПараметрыМетода.Вставить(КодПотока,ПараметрыВызоваСервера);
// ===================================
ИмяФункцииИлиПроцедуры = "ОбщийМодуль1.ПроцедураМногопоток";
ФоновоеЗадание = ДлительныеОперации.ВыполнитьПроцедуруВНесколькоПотоков(ИмяФункцииИлиПроцедуры, ПараметрыВыполнения, ПараметрыМетода);
Если ФоновоеЗадание.Статус = "Ошибка" Тогда
Сообщить(СокрЛП(ФоновоеЗадание.Статус));
КонецЕсли;
Возврат ФоновоеЗадание;
КонецФункции
&НаКлиенте
Процедура ПрогрессВыполнения(Результат, ДополнительныеПараметры) Экспорт
КонецПроцедуры
&НаСервереБезКонтекста
Функция ПрочитатьПрогресс(ИдентификаторЗадания)
Возврат ДлительныеОперации.ПрочитатьПрогресс(ИдентификаторЗадания);
КонецФункции
&НаКлиенте
Процедура ОбработатьДанные(Задание, ДополнительныеПараметры) Экспорт
Если Задание = Неопределено Тогда
Возврат;
КонецЕсли;
ЭтаФорма.РезультатВыполнения = СокрЛП(Задание.Статус) +" "+СокрЛП(ПолучитьИЗВременногоХранилища(Задание.АдресРезультата));
КонецПроцедурыЗаключение и выводы
В статье попробовал использовать функционал многопоточности - запустил искусственную процедуру общего модуля с разными параметрами параллельно (при одних значениях параметрах). Задача выполнена. Спасибо за прочтение материала, надеюсь, что данная статья будет кому-то полезна.
