Функция ТекущийПоток(): данные и событие завершения потока исполнения

src/OneScript.StandardLibrary/StandardGlobalContext.cs

@@ -75,6 +75,28 @@ public void RunGarbageCollection()
             GC.WaitForPendingFinalizers();
         }
 
+        /// <summary>
+        /// Возвращает идентификатор потока исполнения, в котором выполняется текущий код.
+        ///
+        /// Каждая независимая единица исполнения bsl-кода получает собственный идентификатор:
+        /// основной скрипт, каждое фоновое задание и каждый обрабатываемый запрос веб-сервера.
+        /// Идентификаторы уникальны в пределах запущенного движка и не переиспользуются.
+        ///
+        /// Метод предназначен для библиотек, которым нужно хранить данные в разрезе единицы
+        /// исполнения (аналог thread-local хранилища). В отличие от идентификатора фонового задания,
+        /// значение определено во всех контекстах, в том числе при обработке запросов веб-сервера,
+        /// где фоновое задание отсутствует.
+        ///
+        /// Идентификатор не наследуется: фоновое задание, запущенное из текущего потока исполнения,
+        /// получит собственное значение.
+        /// </summary>
+        /// <returns>Число. Идентификатор текущего потока исполнения.</returns>
+        [ContextMethod("ИдентификаторПотокаИсполнения", "ExecutionThreadId")]
+        public int ExecutionThreadId(IBslProcess process)
+        {
+            return process.VirtualThreadId;
+        }
+
         /// <summary>
         /// Приостанавливает выполнение скрипта.
         /// </summary>

src/OneScript.Web.Server/WebServer.cs

@@ -123,8 +123,7 @@ private void ConfigureApp()
 
             _app.Use((context, next) =>
             {
-                var process = _executionContext.Services.Resolve<IBslProcessFactory>().NewProcess();
-                context.Items.Add(typeof(IBslProcess), process);
+                GetOrCreateProcess(context);
                 return next();
             });
 
@@ -178,7 +177,11 @@ private void UseBslExceptionHandler()
                     var methodNumber = _exceptionHandler?.Target.GetMethodNumber(_exceptionHandler?.MethodName)
                         ?? throw new InvalidOperationException();
 
-                    var process = _executionContext.Services.Resolve<IBslProcessFactory>().NewProcess();
+                    // Обработчик исключений работает в том же процессе, что и обработчик запроса,
+                    // поэтому видит контекст исполнения, в котором возникла ошибка.
+                    // Собственный процесс создаётся только если исключение возникло до того,
+                    // как процесс запроса был создан (например, в middleware статических файлов).
+                    var process = GetOrCreateProcess(context);
 
                     try
                     {
@@ -197,6 +200,22 @@ private void UseBslExceptionHandler()
             });
         }
 
+        /// <summary>
+        /// Возвращает bsl-процесс, обслуживающий текущий запрос, создавая его при первом обращении.
+        /// Один запрос всегда обслуживается одним процессом, поэтому весь bsl-код запроса
+        /// видит один и тот же ИдентификаторПотокаИсполнения.
+        /// </summary>
+        private IBslProcess GetOrCreateProcess(HttpContext context)
+        {
+            if (context.Items.TryGetValue(typeof(IBslProcess), out var stored) && stored is IBslProcess existing)
+                return existing;
+
+            var process = _executionContext.Services.Resolve<IBslProcessFactory>().NewProcess();
+            context.Items[typeof(IBslProcess)] = process;
+
+            return process;
+        }
+
         private static void WriteExceptionToResponse(HttpContext httpContext, Exception ex)
         {
             httpContext.Response.StatusCode = 500;

tests/tasks.os

@@ -24,6 +24,7 @@
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоВозвращаетсяРезультатДелегата");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоРаботаетБлокировка");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоКодМожетОпределитьИДЗадания");
+	ВсеТесты.Добавить("ТестДолжен_ПроверитьУникальностьИдентификатораПотокаИсполнения");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПотокобезопасностьПолучитьТекущее");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПотокобезопасностьПолучитьФоновыеЗадания");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПоискТекущегоСредиМножестваЗавершенных");
@@ -276,6 +277,38 @@
 
 КонецПроцедуры
 
+Функция ВернутьИдентификаторПотокаИсполнения() Экспорт
+
+	Приостановить(500);
+	Возврат ИдентификаторПотокаИсполнения();
+
+КонецФункции
+
+Процедура ТестДолжен_ПроверитьУникальностьИдентификатораПотокаИсполнения() Экспорт
+
+	ИдОсновногоПотока = ИдентификаторПотокаИсполнения();
+	юТест.ПроверитьРавенство(ИдОсновногоПотока, ИдентификаторПотокаИсполнения(),
+		"Идентификатор потока исполнения должен быть одинаковым при повторном вызове");
+
+	МассивЗаданий = Новый Массив;
+	Для Сч = 1 По 4 Цикл
+		МассивЗаданий.Добавить(ФоновыеЗадания.Выполнить(ЭтотОбъект, "ВернутьИдентификаторПотокаИсполнения"));
+	КонецЦикла;
+
+	ФоновыеЗадания.ОжидатьВсе(МассивЗаданий);
+
+	УникальныеИдентификаторы = Новый Соответствие;
+	Для Каждого Задание Из МассивЗаданий Цикл
+		юТест.ПроверитьНеРавенство(ИдОсновногоПотока, Задание.Результат,
+			"Фоновое задание должно получить собственный идентификатор потока исполнения");
+		УникальныеИдентификаторы.Вставить(Задание.Результат, Истина);
+	КонецЦикла;
+
+	юТест.ПроверитьРавенство(МассивЗаданий.Количество(), УникальныеИдентификаторы.Количество(),
+		"Идентификаторы потоков исполнения одновременных фоновых заданий должны различаться");
+
+КонецПроцедуры
+
 Процедура ТестДолжен_ПроверитьЧтоВИнформацииОбОшибкеЕстьСтекВызовов() Экспорт
 
 	Задание = ФоновыеЗадания.Выполнить(ЭтотОбъект, "ПроцедураСИсключением");