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

Введение

В этой статье решил привести небольшой программный эксперимент - позапускать собственную процедуру общего модуля конфигурации в многопоточном режиме, используя относительно новые методы библиотеки стандартных подсистем - набора модулей ДлительныеОперации. Разработку примеров я буду вести на типовой конфигурации БСП - версии 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.ПроцедураМногопоток";
	
	ФоновоеЗадание = ДлительныеОперации.ВыполнитьПроцедуруВНесколькоПотоков(ИмяФункцииИлиПроцедуры, ПараметрыВыполнения, ПараметрыМетода);
		
   	Если ФоновоеЗадание.Статус = "Ошибка" Тогда
		Сообщить(СокрЛП(ФоновоеЗадание.Статус));
	КонецЕсли;

	
	Возврат ФоновоеЗадание;	
	
КонецФункции	

&НаКлиенте
Процедура ПрогрессВыполнения(Результат, ДополнительныеПараметры) Экспорт
	
КонецПроцедуры

&НаСервереБезКонтекста
Функция ПрочитатьПрогресс(ИдентификаторЗадания)
	Возврат ДлительныеОперации.ПрочитатьПрогресс(ИдентификаторЗадания);
КонецФункции

&НаКлиенте
Процедура ОбработатьДанные(Задание, ДополнительныеПараметры) Экспорт

	Если Задание = Неопределено Тогда
		Возврат;
	КонецЕсли;  
	
	ЭтаФорма.РезультатВыполнения = СокрЛП(Задание.Статус) +" "+СокрЛП(ПолучитьИЗВременногоХранилища(Задание.АдресРезультата));
	
КонецПроцедуры

Заключение и выводы

В статье попробовал использовать функционал многопоточности - запустил искусственную процедуру общего модуля с разными параметрами параллельно (при одних значениях параметрах). Задача выполнена. Спасибо за прочтение материала, надеюсь, что данная статья будет кому-то полезна.