1. Модуль АсинхронностьСлужебный переименован в ОбещанияСлужебный

2. В API добавлена возможность ожидать завершения массива обещаний

Author: sfaqer

README.md

@@ -37,6 +37,18 @@
 Функция ВыполнитьДелегат(Действие, Параметры)
 ```
 
+#### ОжидатьВсе
+
+```bsl
+// Ожидает исполнение всех переданных обещаний
+//
+// Параметры:
+//  Обещания - Массив из Обещание - Обещания которых ожидаем
+//  Таймаут -  Число- Количество миллисекунд по истечении которых будет выброшено исключение
+//
+Процедура ОжидатьВсе(Обещания, Таймаут = 0) Экспорт
+```
+
 ### Класс Обещание
 
 #### Получить

packagedef

@@ -1,5 +1,5 @@
 Описание.Имя("async")
-        .Версия("0.2.0")
+        .Версия("0.2.1")
         .Автор("Кирилл Черненко")
         .АдресАвтора("https://github.com/sfaqer")
         .Описание("Фреймворк асинхронного исполнения для OneScript")
@@ -13,4 +13,5 @@
         .РазработкаЗависитОт("json")
         .РазработкаЗависитОт("asserts")
         .ЗависитОт("lambdas", "0.1.3")
+        .ЗависитОт("fluent", "0.6.1")
         ;

src/internal/Классы/Обещание.os

@@ -58,7 +58,7 @@
 
 	Результат = Новый Обещание(Алгоритм, ЭтотОбъект);
 
-	АсинхронностьСлужебный.ЗапуститьВыполнениеОбещания(Результат);
+	ОбещанияСлужебный.ЗапуститьВыполнениеОбещания(Результат);
 
 	Возврат Результат;
 
@@ -88,7 +88,7 @@
 
 	Результат = Новый Обещание(Алгоритм, ЭтотОбъект, Истина);
 
-	АсинхронностьСлужебный.ЗапуститьВыполнениеОбещания(Результат);
+	ОбещанияСлужебный.ЗапуститьВыполнениеОбещания(Результат);
 
 	Возврат Результат;
 

src/internal/Модули/АсинхронностьСлужебный.os renamed to src/internal/Модули/ОбещанияСлужебный.os

@@ -1,3 +1,5 @@
+#Использовать fluent
+
 #Область ОписаниеПеременных
 
 Перем Рефлектор; // Для доступа к приватным полям обещания
@@ -61,6 +63,20 @@
 
 КонецФункции
 
+Процедура ОжидатьВсе(Обещания, Таймаут) Экспорт
+
+	Задания = ПроцессорыКоллекций.ИзКоллекции(Обещания)
+		.Обработать("Обещание -> Рефлектор.ПолучитьСвойство(Обещание, ""Задание"")", ЭтотОбъект)
+		.ВМассив();
+
+	Результат = ФоновыеЗадания.ОжидатьВсе(Задания, Таймаут);
+
+	Если Не Результат Тогда
+		ВызватьИсключение "Превышено время ожидания получения результата";
+	КонецЕсли;
+
+КонецПроцедуры
+
 #КонецОбласти
 
 Рефлектор = Новый Рефлектор();

src/Модули/Обещания.os

@@ -21,7 +21,7 @@
 
 	Результат = Новый Обещание(Алгоритм, Параметры);
 
-	АсинхронностьСлужебный.ЗапуститьВыполнениеОбещания(Результат);
+	ОбещанияСлужебный.ЗапуститьВыполнениеОбещания(Результат);
 
 	Возврат Результат;
 
@@ -40,10 +40,20 @@
 
 	Результат = Новый Обещание(Действие, Параметры);
 
-	АсинхронностьСлужебный.ЗапуститьВыполнениеОбещания(Результат);
+	ОбещанияСлужебный.ЗапуститьВыполнениеОбещания(Результат);
 
 	Возврат Результат;
 
 КонецФункции
 
+// Ожидает исполнение всех переданных обещаний
+//
+// Параметры:
+//  Обещания - Массив из Обещание - Обещания которых ожидаем
+//  Таймаут -  Число- Количество миллисекунд по истечении которых будет выброшено исключение
+//
+Процедура ОжидатьВсе(Обещания, Таймаут = 0) Экспорт
+	ОбещанияСлужебный.ОжидатьВсе(Обещания, Таймаут);
+КонецПроцедуры
+
 #КонецОбласти

tests/Обещания.os

@@ -46,6 +46,80 @@
 
 КонецПроцедуры
 
+&Тест
+Процедура ОжидаемВсе() Экспорт
+
+	// Дано
+
+	Параметры = Новый Массив();
+	Параметры.Добавить(1);
+	Параметры.Добавить(2);
+
+	Ждем = Новый Массив();
+
+	// BSLLS:DuplicatedInsertionIntoCollection-off
+	// BSLLS:DuplicateStringLiteral-off
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	// BSLLS:DuplicatedInsertionIntoCollection-on
+	// BSLLS:DuplicateStringLiteral-on
+
+	// Когда
+
+	Обещания.ОжидатьВсе(Ждем);
+
+	// Тогда
+
+	Для каждого Обещание Из Ждем Цикл
+
+		Утверждения.ПроверитьРавенство(Обещание.Состояние(), СостояниеФоновогоЗадания.Завершено);
+		Утверждения.ПроверитьРавенство(Обещание.Получить(), 3);
+
+	КонецЦикла;
+
+КонецПроцедуры
+
+Процедура НеДождалисьВсех() Экспорт
+
+	// Дано
+
+	Параметры = Новый Массив();
+	Параметры.Добавить(1);
+	Параметры.Добавить(2);
+
+	Ждем = Новый Массив();
+
+	// BSLLS:DuplicatedInsertionIntoCollection-off
+	// BSLLS:DuplicateStringLiteral-off
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	Ждем.Добавить(Обещания.ВыполнитьЛямбду("(П, В) -> Возврат СложитьСЗадержкой(П, В)", ЭтотОбъект, Параметры));
+	// BSLLS:DuplicatedInsertionIntoCollection-on
+	// BSLLS:DuplicateStringLiteral-on
+
+	// Тогда
+
+	Параметры = Новый Массив;
+	Параметры.Добавить(Ждем);
+	Параметры.Добавить(10);
+
+	Ожидаем.Что(Обещания)
+		.Метод("ОжидатьВсе", Параметры)
+		.ВыбрасываетИсключение("Превышено время ожидания получения результата");
+
+КонецПроцедуры
+
 Функция СложитьСЗадержкой(Первое, Второе) Экспорт
 
 	Приостановить(100);