Инициализация функциональных интерфейсов сделана потокобезопасной

Author: sfaqer

packagedef

@@ -1,5 +1,5 @@
 Описание.Имя("lambdas")
-        .Версия("0.3.2")
+        .Версия("0.3.3")
         .Автор("Кирилл Черненко")
         .АдресАвтора("https://github.com/sfaqer")
         .Описание("API для реализации функциональных интерфейсов для OneScript")

src/Модули/ФункциональныеИнтерфейсы.os

@@ -8,22 +8,18 @@
 Перем Запускаемый;  // Кеш интерфейса Запускаемый
 Перем УниПроцедура; // Кеш интерфейса УниПроцедура
 Перем БиПроцедура;  // Кеш интерфейса БиПроцедура
-Перем ТриПроцедура; // Кеш интерфейса ТриПроцедура 
+Перем ТриПроцедура; // Кеш интерфейса ТриПроцедура
+
+Перем БлокировкаРесурса; // Мьютекс для синхронизации
 
 // Возвращает интерфейс объекта содержащий функцию без параметров
 //
 //  Возвращаемое значение:
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция Вызываемый() Экспорт
-	
-	Если Не ЗначениеЗаполнено(Вызываемый) Тогда
-		Вызываемый = Новый ИнтерфейсОбъекта();
-		Вызываемый.ИзОбъекта(Тип("Вызываемый"));
-	КонецЕсли;
-
+	Вызываемый = ИнициализироватьИнтерфейс(Вызываемый, Тип("Вызываемый"));
 	Возврат Вызываемый;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий функцию с одним параметром
@@ -32,14 +28,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция УниФункция() Экспорт
-	
-	Если Не ЗначениеЗаполнено(УниФункция) Тогда
-		УниФункция = Новый ИнтерфейсОбъекта();
-		УниФункция.ИзОбъекта(Тип("УниФункция"));
-	КонецЕсли;
-
+	УниФункция = ИнициализироватьИнтерфейс(УниФункция, Тип("УниФункция"));
 	Возврат УниФункция;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий функцию с двумя параметрами
@@ -48,14 +38,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция БиФункция() Экспорт
-
-	Если Не ЗначениеЗаполнено(БиФункция) Тогда
-		БиФункция = Новый ИнтерфейсОбъекта();
-		БиФункция.ИзОбъекта(Тип("БиФункция"));
-	КонецЕсли;
-
+	БиФункция = ИнициализироватьИнтерфейс(БиФункция, Тип("БиФункция"));
 	Возврат БиФункция;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий функцию с тремя параметрами
@@ -64,14 +48,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция ТриФункция() Экспорт
-
-	Если Не ЗначениеЗаполнено(ТриФункция) Тогда
-		ТриФункция = Новый ИнтерфейсОбъекта();
-		ТриФункция.ИзОбъекта(Тип("ТриФункция"));
-	КонецЕсли;
-
+	ТриФункция = ИнициализироватьИнтерфейс(ТриФункция, Тип("ТриФункция"));
 	Возврат ТриФункция;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий процедуру без параметров
@@ -80,14 +58,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция Запускаемый() Экспорт
-	
-	Если Не ЗначениеЗаполнено(Запускаемый) Тогда
-		Запускаемый = Новый ИнтерфейсОбъекта();
-		Запускаемый.ИзОбъекта(Тип("Запускаемый"));
-	КонецЕсли;
-
+	Запускаемый = ИнициализироватьИнтерфейс(Запускаемый, Тип("Запускаемый"));
 	Возврат Запускаемый;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий процедуру с одним параметром
@@ -96,14 +68,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция УниПроцедура() Экспорт
-
-	Если Не ЗначениеЗаполнено(УниПроцедура) Тогда
-		УниПроцедура = Новый ИнтерфейсОбъекта();
-		УниПроцедура.ИзОбъекта(Тип("УниПроцедура"));
-	КонецЕсли;
-
+	УниПроцедура = ИнициализироватьИнтерфейс(УниПроцедура, Тип("УниПроцедура"));
 	Возврат УниПроцедура;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий процедуру с двумя параметрами
@@ -112,14 +78,8 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция БиПроцедура() Экспорт
-
-	Если Не ЗначениеЗаполнено(БиПроцедура) Тогда
-		БиПроцедура = Новый ИнтерфейсОбъекта();
-		БиПроцедура.ИзОбъекта(Тип("БиПроцедура"));
-	КонецЕсли;
-
+	БиПроцедура = ИнициализироватьИнтерфейс(БиПроцедура, Тип("БиПроцедура"));
 	Возврат БиПроцедура;
-
 КонецФункции
 
 // Возвращает интерфейс объекта содержащий процедуру с тремя параметрами
@@ -128,12 +88,23 @@
 //   ИнтерфейсОбъекта - Искомый интерфейс
 //
 Функция ТриПроцедура() Экспорт
+	ТриПроцедура = ИнициализироватьИнтерфейс(ТриПроцедура, Тип("ТриПроцедура"));
+	Возврат ТриПроцедура;
+КонецФункции
 
-	Если Не ЗначениеЗаполнено(ТриПроцедура) Тогда
-		ТриПроцедура = Новый ИнтерфейсОбъекта();
-		ТриПроцедура.ИзОбъекта(Тип("ТриПроцедура"));
+Функция ИнициализироватьИнтерфейс(Знач Интерфейс, Тип)
+
+	Если Не ЗначениеЗаполнено(Интерфейс) Тогда
+		БлокировкаРесурса.Заблокировать();
+		Если Не ЗначениеЗаполнено(Интерфейс) Тогда
+			Интерфейс = Новый ИнтерфейсОбъекта();
+			Интерфейс.ИзОбъекта(Тип);
+		КонецЕсли;
+		БлокировкаРесурса.Разблокировать();
 	КонецЕсли;
 
-	Возврат ТриПроцедура;
+	Возврат Интерфейс;
 
 КонецФункции
+
+БлокировкаРесурса = Новый БлокировкаРесурса();

tests/ФункциональныеИнтерфейсы.os

@@ -71,3 +71,84 @@
 		.Равно(ФункциональныеИнтерфейсы.ТриПроцедура());
 
 КонецПроцедуры
+
+&Тест
+Процедура ФункциональныеИнтерфейсыПотокобезопасны() Экспорт
+
+	// Дано
+	Рефлектор = Новый Рефлектор();
+	Рефлектор.УстановитьСвойство(ФункциональныеИнтерфейсы, "Вызываемый", Неопределено);
+
+	// Когда
+
+	Результаты = ВыполнитьВПятьсотПотоков(ЭтотОбъект, "ПроверитьИнтерфейс");
+
+	// Тогда
+
+	Для каждого Результат Из Результаты Цикл
+		Ожидаем.Что(Результат)
+			.ИмеетТип("Строка")
+			.Равно("Вызвать");
+	КонецЦикла;
+
+КонецПроцедуры
+
+Функция ПроверитьИнтерфейс() Экспорт
+
+	Возврат ФункциональныеИнтерфейсы.Вызываемый()
+		.ПолучитьКартуИнтерфейса()
+		[0]
+		.Имя;
+
+КонецФункции
+
+Функция ВыполнитьВПятьсотПотоков(
+	Сценарий,
+	ИмяМетода,
+	Параметр = Неопределено,
+	ВторойПараметр = Неопределено,
+	ТретийПараметр = Неопределено)
+	
+	Параметры = Новый Массив;
+
+	Если Не Параметр = Неопределено Тогда
+		Параметры.Добавить(Параметр);
+	КонецЕсли;
+
+	Если Не ВторойПараметр = Неопределено Тогда
+		Параметры.Добавить(ВторойПараметр);
+	КонецЕсли;
+
+	Если Не ТретийПараметр = Неопределено Тогда
+		Параметры.Добавить(ТретийПараметр);
+	КонецЕсли;
+
+	Задания = Новый Массив();
+
+	Для Счетчик = 1 По 500 Цикл // BSLLS:UnusedLocalVariable-off
+
+		Задания.Добавить(
+			ФоновыеЗадания.Выполнить(Сценарий, ИмяМетода, Параметры)
+		);
+
+	КонецЦикла;
+
+	ФоновыеЗадания.ОжидатьВсе(Задания);
+
+	Для каждого ФоновоеЗадание Из Задания Цикл
+
+		Если ФоновоеЗадание.Состояние = СостояниеФоновогоЗадания.ЗавершеноАварийно Тогда
+			ВызватьИсключение ФоновоеЗадание.ИнформацияОбОшибке;
+		КонецЕсли;
+
+	КонецЦикла;
+
+	Результаты = Новый Массив;
+
+	Для каждого ФоновоеЗадание Из Задания Цикл
+		Результаты.Добавить(ФоновоеЗадание.Результат);
+	КонецЦикла;
+
+	Возврат Результаты;
+
+КонецФункции