Thread safety

Pilz/Data/Json/JsonDataContainer.cs

@@ -8,6 +8,8 @@ public abstract class JsonDataContainer
     protected readonly HashSet<object> sets = [];
 
     public virtual HashSet<T>? Set<T>(bool allowCreate) where T : class, IDataObject
+    {
+        lock (sets)
         {
             var list = sets.OfType<HashSet<T>>().FirstOrDefault();
 
@@ -19,12 +21,16 @@ public abstract class JsonDataContainer
 
             return list;
         }
+    }
 
     public virtual void CopyTo(JsonDataContainer container)
+    {
+        lock (sets)
         {
             foreach (var set in sets)
                 container.sets.Add(set);
         }
+    }
 
     protected virtual JsonSerializer GetSerializer()
     {

Pilz/Data/Json/JsonDataManager.cs

@@ -21,9 +21,7 @@ public class JsonDataManager(JsonDataContainer container) : DataManager
 
     protected override void UpdateEntity<T>(T obj)
     {
-        var set = container.Set<T>(true);
+        container.Set<T>(true).Add(obj);
-        if (!set.Contains(obj))
-            set.Add(obj);
     }
 
     protected override void SaveChanges()

Pilz/Data/Json/JsonFileContainer.cs

@@ -2,15 +2,23 @@
 
 public class JsonFileContainer(string filePath) : JsonDataContainer
 {
+    protected readonly object _lock_FileAction = new();
+
     public override void Read()
+    {
+        lock (_lock_FileAction)
         {
             using var sw = new StreamReader(filePath);
             GetSerializer().Populate(sw, this);
         }
+    }
 
     public override void Flush()
+    {
+        lock (_lock_FileAction)
         {
             using var sw = new StreamWriter(filePath, false);
             GetSerializer().Serialize(sw, this);
         }
+    }
 }

Pilz/Data/Json/JsonStreamContainer.cs

@@ -2,18 +2,25 @@
 
 public class JsonStreamContainer(Stream stream) : JsonDataContainer
 {
+    protected readonly object _lock_StreamAction = new();
     public override void Read()
+    {
+        lock (_lock_StreamAction)
         {
             using var sw = new StreamReader(stream);
             stream.Position = 0;
             GetSerializer().Populate(sw, this);
         }
+    }
 
     public override void Flush()
+    {
+        lock (_lock_StreamAction)
         {
             using var sw = new StreamWriter(stream);
             stream.Position = 0;
             GetSerializer().Serialize(sw, this);
             stream.SetLength(stream.Position);
         }
+    }
 }

Pilz/Pilz.csproj

@@ -5,7 +5,7 @@
     <LangVersion>latest</LangVersion>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>annotations</Nullable>
-    <Version>2.4.2</Version>
+    <Version>2.4.3</Version>
   </PropertyGroup>
   
   <ItemGroup>