Потокобезопасные общие кэши маршаллинга перечислений и нативного компилятора

src/OneScript.Core/Commons/LruCache.cs

@@ -10,6 +10,10 @@ This Source Code Form is subject to the terms of the
 
 namespace OneScript.Commons
 {
+    /// <summary>
+    /// Не потокобезопасен: даже чтение меняет порядок элементов.
+    /// Общий для нескольких потоков кэш нужно защищать блокировкой снаружи.
+    /// </summary>
     public class LruCache<TKey, TValue>
     {
         private readonly int _capacity;

src/OneScript.Native/Compiler/ReflectedMembersCache.cs

@@ -13,6 +13,9 @@ namespace OneScript.Native.Compiler
 {
     public abstract class ReflectedMembersCache<T> where T : MemberInfo
     {
+        // Кэши в ExpressionHelpers статические и общие для всех потоков
+        private readonly object _lock = new object();
+
         private readonly LruCache<string, T> _cache;
 
         public ReflectedMembersCache() : this(128)
@@ -32,8 +35,11 @@ public virtual T GetOrAdd(Type type, string name)
         public T GetOrAdd(Type type, string name, BindingFlags flags)
         {
             var key = $"{type.Name}.{name}";
-            return _cache.GetOrAdd(key, x => SearchImpl(type, name, flags) 
-                                             ?? throw new InvalidOperationException($"No member found {key}"));
+            lock (_lock)
+            {
+                return _cache.GetOrAdd(key, x => SearchImpl(type, name, flags)
+                                                 ?? throw new InvalidOperationException($"No member found {key}"));
+            }
         }
 
         protected abstract T SearchImpl(Type type, string name, BindingFlags flags);

src/ScriptEngine/Machine/Contexts/SimpleEnumsMarshaller.cs

@@ -6,6 +6,7 @@ This Source Code Form is subject to the terms of the
 ----------------------------------------------------------*/
 
 using System;
+using System.Collections.Concurrent;
 using System.Diagnostics;
 using System.Linq.Expressions;
 using System.Reflection;
@@ -21,8 +22,9 @@ public static class SimpleEnumsMarshaller
     {
         // TODO Наверное можно и прямо отсюда регистрировать SimpleEnum-ы а из ContextDiscoverer этот класс вызывать
 
-        private static LruCache<Type, Func<object, EnumerationValue>> _gettersCache 
-            = new LruCache<Type, Func<object, EnumerationValue>>(32);
+        // Общий на все потоки. Типов перечислений конечное число, вытеснять нечего
+        private static readonly ConcurrentDictionary<Type, Func<object, EnumerationValue>> _gettersCache
+            = new ConcurrentDictionary<Type, Func<object, EnumerationValue>>();
 
         /// <summary>
         /// Получить IValue для значения clr-перечисления.

src/ScriptEngine/Machine/LruCache.cs

@@ -10,6 +10,10 @@ This Source Code Form is subject to the terms of the
 
 namespace ScriptEngine.Machine
 {
+    /// <summary>
+    /// Не потокобезопасен: даже чтение меняет порядок элементов.
+    /// Общий для нескольких потоков кэш нужно защищать блокировкой снаружи.
+    /// </summary>
     public class LruCache<TKey, TValue>
     {
         private readonly int _capacity;

src/Tests/OneScript.Dynamic.Tests/ReflectedMembersCacheTest.cs

@@ -0,0 +1,37 @@
+/*----------------------------------------------------------
+This Source Code Form is subject to the terms of the
+Mozilla Public License, v.2.0. If a copy of the MPL
+was not distributed with this file, You can obtain one
+at http://mozilla.org/MPL/2.0/.
+----------------------------------------------------------*/
+
+using System;
+using System.Threading.Tasks;
+using FluentAssertions;
+using OneScript.Native.Compiler;
+using Xunit;
+
+namespace OneScript.Dynamic.Tests;
+
+public class ReflectedMembersCacheTest
+{
+    [Fact]
+    public void CacheSurvivesParallelAccess()
+    {
+        // имен больше емкости: и попадания, и вытеснение
+        var cache = new ReflectedMethodsCache(4);
+        var names = new[] { "Sin", "Cos", "Tan", "Sqrt", "Exp", "Log10" };
+
+        Action act = () => Parallel.For(0, 8, _ =>
+        {
+            for (var i = 0; i < 100000; i++)
+            {
+                var name = names[i % names.Length];
+                if (cache.GetOrAdd(typeof(Math), name).Name != name)
+                    throw new InvalidOperationException($"Wrong method for {name}");
+            }
+        });
+
+        act.Should().NotThrow();
+    }
+}

tests/tasks.os

@@ -41,6 +41,7 @@
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоВИнформацииОбОшибкеЕстьСтекВызовов");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьЧтоОбработчикиСобытийВызываютсяВФоновомЗадании");
 	ВсеТесты.Добавить("ТестДолжен_ПроверитьПараллельноеЧтениеЗначенияСистемногоПеречисления");
+	ВсеТесты.Добавить("ТестДолжен_ПроверитьПараллельноеЧтениеСвойстваПеречисления");
 
 	Возврат ВсеТесты;
 
@@ -669,6 +670,30 @@
 
 КонецПроцедуры
 
+Процедура ПрочитатьСостояниеЗадания(Задание) Экспорт
+	Для Счетчик = 1 По 50000 Цикл
+		Состояние = Задание.Состояние;
+	КонецЦикла;
+КонецПроцедуры
+
+Процедура ТестДолжен_ПроверитьПараллельноеЧтениеСвойстваПеречисления() Экспорт
+
+	Задание = ФоновыеЗадания.Выполнить(ЭтотОбъект, "Пустышка");
+	Задание.ОжидатьЗавершения(60000);
+
+	Параметры = Новый Массив;
+	Параметры.Добавить(Задание);
+
+	Задания = Новый Массив;
+	Для НомерЗадания = 1 По 8 Цикл
+		Задания.Добавить(ФоновыеЗадания.Выполнить(ЭтотОбъект, "ПрочитатьСостояниеЗадания", Параметры));
+	КонецЦикла;
+
+	ФоновыеЗадания.ОжидатьВсе(Задания);
+	ПроверитьОтсутствиеОшибокВЗаданиях(Задания);
+
+КонецПроцедуры
+
 Процедура Пустышка() Экспорт
 КонецПроцедуры