Какие-то фиксы

Author: nixel2007

src/Классы/ПулСоединений.os

@@ -28,9 +28,11 @@
 	Карта_КоннекторНаКонтекст = Новый Соответствие;
 
 	// Создаем начальный набор соединений
-	Для Индекс = 1 По РазмерПула Цикл
+	Счетчик = 0;
+	Пока Счетчик < РазмерПула Цикл
 		Соединение = СоздатьНовоеСоединение();
 		ДоступныеСоединения.Добавить(Соединение);
+		Счетчик = Счетчик + 1;
 	КонецЦикла;
 КонецПроцедуры
 
@@ -131,46 +133,16 @@
 	Карта_КоннекторНаКонтекст.Очистить();
 КонецПроцедуры
 
-// Очистить завершенные контексты
-// Проверяет статус фоновых заданий и освобождает соединения завершенных контекстов
-// При недоступности API фоновых заданий использует эвристическую очистку
-//
 Процедура ОчиститьЗавершенныеКонтексты()
-	Попытка
-		// Пытаемся использовать API фоновых заданий для точной очистки
-		Если ТипЗнч(ФоновыеЗадания) = Тип("МенеджерФоновыхЗаданий") Тогда
-			ОчиститьЗавершенныеКонтексты_ЧерезAPI();
+	КонтекстыДляПроверки = Новый Массив;
+	Для Каждого Элемент Из Карта_КонтекстНаКоннектор Цикл
+		КонтекстыДляПроверки.Добавить(Элемент.Ключ);
+	КонецЦикла;
+	Для Каждого КонтекстID Из КонтекстыДляПроверки Цикл
+		Если ПроверитьЗавершениеКонтекста(КонтекстID) Тогда
+			ОсвободитьКонтекст(КонтекстID);
 		КонецЕсли;
-	Исключение
-		// Если API недоступен или возникла ошибка, используем эвристическую очистку
-	КонецПопытки;
-	
-	// Эвристическая очистка как запасной вариант
-	ОчиститьЗавершенныеКонтексты_Эвристически();
-КонецПроцедуры
-
-// Очистка завершенных контекстов через API фоновых заданий
-//
-Процедура ОчиститьЗавершенныеКонтексты_ЧерезAPI()
-	Попытка
-		// Получаем список всех контекстов, привязанных к соединениям
-		КонтекстыДляПроверки = Новый Массив;
-		Для Каждого Элемент Из Карта_КонтекстНаКоннектор Цикл
-			КонтекстыДляПроверки.Добавить(Элемент.Ключ);
-		КонецЦикла;
-		
-		// Проверяем каждый контекст
-		Для Каждого КонтекстID Из КонтекстыДляПроверки Цикл
-			КонтекстЗавершен = ПроверитьЗавершениеКонтекста(КонтекстID);
-			Если КонтекстЗавершен Тогда
-				ОсвободитьКонтекст(КонтекстID);
-			КонецЕсли;
-		КонецЦикла;
-		
-	Исключение
-		// Если произошла ошибка при работе с API, просто игнорируем
-		// Эвристическая очистка сработает как запасной вариант
-	КонецПопытки;
+	КонецЦикла;
 КонецПроцедуры
 
 // Проверить, завершен ли контекст (фоновое задание или основной поток)
@@ -207,49 +179,32 @@
 //
 Функция ПроверитьСтатусФоновогоЗадания(ЗаданиеID)
 	Попытка
-		// В OneScript может быть доступен метод для получения задания по ID
-		// Пока используем заглушку, так как точный API неизвестен
-		
-		// Предполагаемый код (когда API будет доступен):
-		// Задание = ФоновыеЗадания.НайтиПоИдентификатору(ЗаданиеID);
-		// Если Задание <> Неопределено Тогда
-		//     Возврат Задание.Состояние = СостояниеФоновогоЗадания.Завершено 
-		//          ИЛИ Задание.Состояние = СостояниеФоновогоЗадания.ЗавершеноАварийно;
-		// КонецЕсли;
-		
-		Возврат Ложь; // Консервативный подход - не освобождаем, пока не уверены
-		
-	Исключение
-		Возврат Ложь; // При ошибке считаем задание активным
-	КонецПопытки;
-КонецФункции
-
-// Эвристическая очистка контекстов для предотвращения утечек памяти
-//
-Процедура ОчиститьЗавершенныеКонтексты_Эвристически()
-	МаксимальноеКоличествоКонтекстов = 100;
-	
-	Если Карта_КонтекстНаКоннектор.Количество() > МаксимальноеКоличествоКонтекстов Тогда
-		// Создаем список контекстов для удаления (самые старые)
-		КонтекстыДляУдаления = Новый Массив;
-		Счетчик = 0;
-		КоличествоДляУдаления = Карта_КонтекстНаКоннектор.Количество() - МаксимальноеКоличествоКонтекстов;
-		
-		Для Каждого Элемент Из Карта_КонтекстНаКоннектор Цикл
-			Если Счетчик < КоличествоДляУдаления Тогда
-				КонтекстыДляУдаления.Добавить(Элемент.Ключ);
-				Счетчик = Счетчик + 1;
+		// Получаем актуальный список заданий. Если задание отсутствует - считаем завершенным.
+		МассивЗаданий = ФоновыеЗадания.ПолучитьФоновыеЗадания();
+		Для Каждого Задание Из МассивЗаданий Цикл
+			Если Задание.УникальныйИдентификатор <> ЗаданиеID Тогда
+				Продолжить;
+			КонецЕсли;
+			Попытка
+				Сост = Задание.Состояние;
+			Исключение
+				// Не удалось получить состояние - считаем активным
+				Возврат Ложь;
+			КонецПопытки;
+			Если Сост = СостояниеФоновогоЗадания.Активно Тогда
+				Возврат Ложь;
 			Иначе
-				Прервать;
+				Возврат Истина;
 			КонецЕсли;
 		КонецЦикла;
-		
-		// Освобождаем старые контексты
-		Для Каждого КонтекстID Из КонтекстыДляУдаления Цикл
-			ОсвободитьКонтекст(КонтекстID);
-		КонецЦикла;
-	КонецЕсли;
-КонецПроцедуры
+
+		// Не нашли задание - вероятно завершено и очищено менеджером
+		Возврат Истина;
+	Исключение
+		// При любой ошибке (например, свойство недоступно) возвращаем Ложь - не освобождаем раньше времени
+		Возврат Ложь;
+	КонецПопытки;
+КонецФункции
 
 // Создать новое соединение
 //

tests/МногопоточностьФоновыеЗадания.os

@@ -248,22 +248,6 @@
 // Проверяет многопоточную работу менеджера сущностей в режиме фоновых заданий
 &Тест
 Процедура МногопоточнаяРаботаСФоновымиЗаданиями() Экспорт
-	// Проверяем доступность API фоновых заданий
-	
-	ДоступныФоновыеЗадания = Ложь;
-	Попытка
-		Если ТипЗнч(ФоновыеЗадания) = Тип("МенеджерФоновыхЗаданий") Тогда
-			ДоступныФоновыеЗадания = Истина;
-		КонецЕсли;
-	Исключение
-		// API фоновых заданий недоступен
-	КонецПопытки;
-	
-	Если НЕ ДоступныФоновыеЗадания Тогда
-		Сообщить("API фоновых заданий недоступен. Выполняем симуляцию многопоточности.");
-		ВыполнитьСимуляциюМногопоточности();
-		Возврат;
-	КонецЕсли;
 
 	// Создаем менеджер с пулом соединений для тестирования
 	ТипКоннекторы = ТипЗнч(МенеджерСущностей.ПолучитьКоннектор());
@@ -297,23 +281,7 @@
 	КонецЦикла;
 
 	// Ждем завершения всех фоновых заданий (максимум 10 секунд)
-	СчетчикОжидания = 0;
-	Пока СчетчикОжидания < 100 Цикл
-		ВсеЗавершены = Истина;
-		Для Каждого Задание Из МассивЗаданий Цикл
-			Если Задание.Состояние = СостояниеФоновогоЗадания.Активно Тогда
-				ВсеЗавершены = Ложь;
-				Прервать;
-			КонецЕсли;
-		КонецЦикла;
-		
-		Если ВсеЗавершены Тогда
-			Прервать;
-		КонецЕсли;
-		
-		Приостановить(100); // 100 мс
-		СчетчикОжидания = СчетчикОжидания + 1;
-	КонецЦикла;
+	ОжидатьЗавершенияВсехЗаданий(МассивЗаданий, 100, 100);
 
 	// Фиксируем транзакцию основного потока
 	МенеджерСПулом.ЗафиксироватьТранзакцию(ОсновнойКонтекстID);
@@ -345,64 +313,35 @@
 	МенеджерСПулом.Закрыть();
 КонецПроцедуры
 
-// Симуляция многопоточности когда API фоновых заданий недоступен
-Процедура ВыполнитьСимуляциюМногопоточности()
-	// Создаем несколько независимых контекстов для имитации многопоточности
-	ТипКоннекторы = ТипЗнч(МенеджерСущностей.ПолучитьКоннектор());
-	МенеджерСПулом = Новый МенеджерСущностей(
-		ТипКоннекторы, 
-		СтрокаСоединенияКоннектора,
-		Неопределено,
-		3
-	);
-	МенеджерСПулом.ДобавитьКлассВМодель(Тип("Автор"));
-	МенеджерСПулом.Инициализировать();
-	
-	// Имитируем параллельную работу нескольких "потоков"
-	МассивКонтекстов = Новый Массив;
-	
-	// "Поток" 1
-	КонтекстID1 = МенеджерСПулом.НачатьТранзакцию();
-	МассивКонтекстов.Добавить(КонтекстID1);
-	
-	Автор1 = Новый Автор;
-	Автор1.Имя = "Поток1";
-	Автор1.ВтороеИмя = "Симуляция";
-	МенеджерСПулом.Сохранить(Автор1, КонтекстID1);
-	
-	// "Поток" 2 
-	КонтекстID2 = МенеджерСПулом.НачатьТранзакцию();
-	МассивКонтекстов.Добавить(КонтекстID2);
-	
-	Автор2 = Новый Автор;
-	Автор2.Имя = "Поток2";
-	Автор2.ВтороеИмя = "Симуляция";
-	МенеджерСПулом.Сохранить(Автор2, КонтекстID2);
-	
-	// "Поток" 3 с ошибкой
-	КонтекстID3 = МенеджерСПулом.НачатьТранзакцию();
-	МассивКонтекстов.Добавить(КонтекстID3);
-	
-	Автор3 = Новый Автор;
-	Автор3.Имя = "Поток3";
-	Автор3.ВтороеИмя = "СОшибкой";
-	МенеджерСПулом.Сохранить(Автор3, КонтекстID3);
-	
-	// Фиксируем первые два, третий откатываем
-	МенеджерСПулом.ЗафиксироватьТранзакцию(КонтекстID1);
-	МенеджерСПулом.ЗафиксироватьТранзакцию(КонтекстID2);
-	МенеджерСПулом.ОтменитьТранзакцию(КонтекстID3); // Имитируем ошибку
-	
-	// Проверяем результат
-	Результат = МенеджерСПулом.ПолучитьКоннектор().ВыполнитьЗапрос("SELECT * FROM Авторы ORDER BY Имя");
-	Ожидаем.Что(Результат, "Должны сохраниться только успешные операции").ИмеетДлину(2);
-	Ожидаем.Что(Результат[0].Имя, "Первый автор").Равно("Поток1");
-	Ожидаем.Что(Результат[1].Имя, "Второй автор").Равно("Поток2");
-	
-	МенеджерСПулом.Закрыть();
+// Ожидать завершения всех переданных фоновых заданий
+//
+// Параметры:
+//   Задания     - Массив       - Массив фоновых заданий (объекты типа ФоновоеЗадание)
+//   МаксИтераций - Число        - Максимальное количество итераций ожидания
+//   ИнтервалМС  - Число        - Пауза между итерациями в миллисекундах
+Процедура ОжидатьЗавершенияВсехЗаданий(Задания, МаксИтераций, ИнтервалМС)
+	СчетчикОжидания = 0;
+	Пока СчетчикОжидания < МаксИтераций Цикл
+		ВсеЗавершены = Истина;
+		Для Каждого Задание Из Задания Цикл
+			Если Задание.Состояние = СостояниеФоновогоЗадания.Активно Тогда
+				ВсеЗавершены = Ложь;
+				Прервать;
+			КонецЕсли;
+		КонецЦикла;
+		Если ВсеЗавершены Тогда
+			Прервать;
+		КонецЕсли;
+		Приостановить(ИнтервалМС);
+		СчетчикОжидания = СчетчикОжидания + 1;
+	КонецЦикла;
 КонецПроцедуры
 
+
 // Процедура для выполнения в фоновом задании
+// Создание автора в отдельной транзакции (используется в тестах фоновых заданий)
+// Параметры:
+//   ПараметрыЗадания - Структура - Данные для выполнения (МенеджерСущностей, НомерЗадания)
 Процедура ФоновоеЗаданиеСозданияАвтора(ПараметрыЗадания) Экспорт
 	МенеджерСущностей = ПараметрыЗадания.МенеджерСущностей;
 
@@ -425,6 +364,9 @@
 КонецПроцедуры
 
 // Процедура для выполнения в фоновом задании с пулом соединений
+// Создание автора при активном пуле соединений (используется в тестах)
+// Параметры:
+//   ПараметрыЗадания - Структура - Данные для выполнения (МенеджерСущностей, НомерЗадания)
 Процедура ФоновоеЗаданиеСозданияАвтораСПулом(ПараметрыЗадания) Экспорт
 	МенеджерСущностей = ПараметрыЗадания.МенеджерСущностей;
 	НомерЗадания = ПараметрыЗадания.НомерЗадания;