Merge remote-tracking branch 'upstream/develop' into feature/bgTasksCallStack

Author: sfaqer

src/OneScript.StandardLibrary/Tasks/BackgroundTasksManager.cs

@@ -47,10 +47,13 @@ public BackgroundTask Execute(IRuntimeContextInstance target, string methodName,
             var task = new BackgroundTask(target, methodName, parameters);
             _tasks.Add(task);
 
+            var eventProcessor = MachineInstance.Current.EventProcessor;
+
             var taskCreationOptions = longRunning ? TaskCreationOptions.LongRunning : TaskCreationOptions.None;
             var worker = new Task(() =>
             {
                 MachineInstance.Current.SetMemory(_runtimeContext);
+                MachineInstance.Current.EventProcessor = eventProcessor;
                 var debugger = _runtimeContext.Services.TryResolve<IDebugController>();
                 debugger?.AttachToThread();
                 try

src/ScriptEngine.HostedScript/DefaultEventProcessor.cs

@@ -72,11 +72,15 @@ public void AddHandler(
             if (!_registeredHandlers.TryGetValue(eventSource, out var handlers))
             {
                 handlers = new Dictionary<string, HandlersList>();
-                handlers[eventName] = new HandlersList();
                 _registeredHandlers[eventSource] = handlers;
             }
 
-            handlers[eventName].Add(handlerScript, handlerMethod);
+            if (!handlers.TryGetValue(eventName, out var handlersList)) {
+                handlersList = new HandlersList();
+                handlers[eventName] = handlersList;
+            }
+            
+            handlersList.Add(handlerScript, handlerMethod);
         }
 
         public void RemoveHandler(
@@ -88,9 +92,13 @@ public void RemoveHandler(
             if (!(handlerTarget is ScriptDrivenObject handlerScript))
                 throw RuntimeException.InvalidArgumentType("handlerTarget");
 
-            if (_registeredHandlers.TryGetValue(eventSource, out var handlers))
+            if (!_registeredHandlers.TryGetValue(eventSource, out var handlers))
             {
-                handlers[eventName].Remove(handlerScript, handlerMethod);
+                return;
+            }
+            
+            if (handlers.TryGetValue(eventName, out var handlersList)) {
+                handlersList.Remove(handlerScript, handlerMethod);
             }
         }
 
@@ -99,7 +107,11 @@ public void HandleEvent(IRuntimeContextInstance eventSource, string eventName, I
             if (!_registeredHandlers.TryGetValue(eventSource, out var handlers)) 
                 return;
 
-            foreach (var handler in handlers[eventName])
+            if (!handlers.TryGetValue(eventName, out var handlersList)) {
+                return;
+            }
+            
+            foreach (var handler in handlersList)
             {
                 handler.Method(eventArgs);
             }

tests/events.os

@@ -16,6 +16,7 @@
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоПодпискаПоОбъектуВидитТолькоЭкспорт");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПодпискуНаСобытиеВВидеВыражения");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПодпискуСОбработчикомВВидеВыражения");
+	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоУИсточникаМожетБытьНесколькоСобытий");
 
 	Возврат ВсеТесты;
 
@@ -175,4 +176,23 @@
 
 КонецПроцедуры
 
+Процедура ТестДолжен_ПроверитьЧтоУИсточникаМожетБытьНесколькоСобытий() Экспорт
+
+	Источник = Новый ТестСобытий;
+
+	ДобавитьОбработчик Источник.МоеСобытие, ОбработчикСобытияВнутр;
+	ДобавитьОбработчик Источник.МоеСобытиеВторое, ОбработчикСобытияВнутр;
+
+    МассивПараметров = Новый Массив;
+    МассивПараметров.Добавить("П1");
+    МассивПараметров.Добавить("П2");
+
+    Источник.СгенерироватьСобытие("МоеСобытие", МассивПараметров);
+    юТест.ПроверитьРавенство(1, СчетчикВызовов);
+
+    Источник.СгенерироватьСобытие("МоеСобытиеВторое", МассивПараметров);
+    юТест.ПроверитьРавенство(2, СчетчикВызовов);
+
+КонецПроцедуры
+
 ПодключитьСценарий(ТекущийСценарий().Источник, "ТестСобытий");

tests/tasks.os

@@ -3,6 +3,8 @@
 Перем глБлокировка;
 Перем глСумма;
 
+Перем СобытиеВызвано;
+
 ////////////////////////////////////////////////////////////////////
 // Программный интерфейс
 
@@ -23,6 +25,7 @@
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоРаботаетБлокировка");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоКодМожетОпределитьИДЗадания");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоВИнформацииОбОшибкеЕстьСтекВызовов");
+	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоОбработчикиСобытийВызываютсяВФоновомЗадании");
 
 	Возврат ВсеТесты;
 
@@ -69,8 +72,12 @@
 
 КонецПроцедуры
 
+Процедура Событие() Экспорт
+	СобытиеВызвано = Истина;
+КонецПроцедуры
+
 Процедура ТестДолжен_ПроверитьСозданиеЗаданий() Экспорт
-	
+
 	Задание = ФоновыеЗадания.Выполнить(ЭтотОбъект, "ПроцедураБезПараметров");
 	юТест.ПроверитьИстину(ЗначениеЗаполнено(Задание.УникальныйИдентификатор));
 	юТест.ПроверитьРавенство("ПроцедураБезПараметров", Задание.ИмяМетода);
@@ -281,3 +288,25 @@
 	юТест.ПроверитьРавенство(СтекВызовов[0].ИмяМодуля, ТекущийСценарий().Источник);
 
 КонецПроцедуры
+
+Процедура ТестДолжен_ПроверитьЧтоОбработчикиСобытийВызываютсяВФоновомЗадании() Экспорт
+
+	СобытиеВызвано = Ложь;
+
+	Параметры = Новый Массив;
+	Параметры.Добавить("ЯСобытие");
+	Параметры.Добавить(Новый Массив);
+
+	ДобавитьОбработчик ЭтотОбъект.ЯСобытие, Событие;
+
+	ФоновоеЗадание = ФоновыеЗадания.Выполнить(ЭтотОбъект, "ВызватьСобытие", Параметры);
+	ФоновоеЗадание.ОжидатьЗавершения();
+
+	УдалитьОбработчик ЭтотОбъект.ЯСобытие, Событие;
+
+	юТест.ПроверитьИстину(
+		СобытиеВызвано,
+		"Ожидали что при вызове события в фоновом задании вызовется, а это не так"
+	);
+
+КонецПроцедуры