Merge pull request #2 from sfaqer/feature/multithreadingSemaphore

Многопоточная работа семафора

packagedef

@@ -5,13 +5,13 @@
 
 
 Описание.Имя("semaphore")
-        .Версия("1.0.2")
+        .Версия("1.1.0")
         .Автор("Nikita Gryzlov")
         .АдресАвтора("nixel2007@gmail.com")
         .Описание("Библиотека для организации ""семафора"" - инструмента ограничения одновременного выполнения участков кода.")
         .ОпределяетКласс("Семафор", "src/Классы/Семафор.os")
         .ОпределяетМодуль("Семафоры", "src/Модули/Семафоры.os")
-        .ВерсияСреды("1.0.18")
+        .ВерсияСреды("1.6.0")
         .ВключитьФайл("src")
         .ВключитьФайл("tests")
         ;

src/Классы/Семафор.os

@@ -1,5 +1,6 @@
 Перем мСчетчик;
 Перем СтандартныйРазмерПаузы;
+Перем БлокировкаРесурса;
 
 // Конструктор.
 //
@@ -14,7 +15,10 @@
 	Иначе
 		мСчетчик = Счетчик;
 	КонецЕсли;
+
 	СтандартныйРазмерПаузы = 10;
+	БлокировкаРесурса      = Новый БлокировкаРесурса(ЭтотОбъект);
+
 КонецПроцедуры
 
 // Осуществить захват семафора.
@@ -28,9 +32,11 @@
 Процедура Захватить(ТаймаутОжидания = 0) Экспорт
 	ВремяНачала = ТекущаяУниверсальнаяДатаВМиллисекундах();
 	Пока Истина Цикл
+		БлокировкаРесурса.Заблокировать();
 		мСчетчик = мСчетчик - 1;
 		Если мСчетчик < 0 Тогда
 			мСчетчик = мСчетчик + 1;
+			БлокировкаРесурса.Разблокировать();
 			Если ЗначениеЗаполнено(ТаймаутОжидания) Тогда
 				ТекущееВремя = ТекущаяУниверсальнаяДатаВМиллисекундах();
 				Если (ВремяНачала + ТаймаутОжидания) < ТекущееВремя Тогда
@@ -39,6 +45,7 @@
 			КонецЕсли;
 			Приостановить(СтандартныйРазмерПаузы);
 		Иначе
+			БлокировкаРесурса.Разблокировать();
 			Прервать;
 		КонецЕсли;
 	КонецЦикла;

tests/Семафор.os

@@ -33,4 +33,71 @@
 
 	Семафор1.Освободить();
 	Семафор2.Освободить();
+
+КонецПроцедуры
+
+&Тест
+Процедура СемафорыСОдинаковымКлючомБлокируютсяМногопоточно() Экспорт
+
+	Параметры = Новый Массив(1);
+	Параметры[0] = Ложь;
+
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+
+	Параметры[0] = Истина;
+
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+	ФоновыеЗадания.Выполнить(ЭтотОбъект, "СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме", Параметры);
+
+	Попытка
+		ФоновыеЗадания.ОжидатьЗавершенияЗадач();
+	Исключение
+
+		МассивЗаданий = ИнформацияОбОшибке().Параметры;
+
+		Если МассивЗаданий <> Неопределено Тогда
+
+			ШаблонТекстаОшибки = 
+				"Ошибки при многопоточной работе семафора:
+				|%1";
+
+			Для Каждого Задание Из МассивЗаданий Цикл
+
+				МассивОшибок = Новый Массив();
+				МассивОшибок.Добавить(Задание.ИнформацияОбОшибке.ПодробноеОписаниеОшибки());
+
+			КонецЦикла;
+
+			ВызватьИсключение СтрШаблон(
+				ШаблонТекстаОшибки,
+				СтрСоединить(МассивОшибок, Символы.ПС)
+			);
+
+		КонецЕсли;
+	КонецПопытки;
+
+КонецПроцедуры
+
+Процедура СемафорыСОдинаковымКлючомБлокируютсяВМногопочтономРежиме(ДолженВызватьИсключение) Экспорт
+
+	Семафор = Семафоры.Получить("тестовый семафор");
+
+	Если ДолженВызватьИсключение Тогда
+
+		ПараметрыМетода = Новый Массив;
+		ПараметрыМетода.Добавить(1000);
+
+		Ожидаем.Что(Семафор).Метод("Захватить", ПараметрыМетода).ВыбрасываетИсключение("Истекло время ожидания");
+
+	Иначе
+
+		Семафор.Захватить();
+		Приостановить(3000);
+		Семафор.Освободить();
+
+	КонецЕсли;
+
 КонецПроцедуры