add try-finally to dynamicsynchronisationblockbehaviour.

Author: fractos

Inversion.Extensibility/Inversion.Extensibility.csproj

@@ -3,8 +3,10 @@
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
     <PackageId>Inversion.Extensibility</PackageId>
-    <Version>1.0.11</Version>
+    <Version>1.0.12</Version>
     <Authors>Adam Christie</Authors>
+    <AssemblyVersion>1.0.12.0</AssemblyVersion>
+    <FileVersion>1.0.12.0</FileVersion>
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />

Inversion.Extensibility/Process/Behaviour/DynamicSynchronisationBlockBehaviour.cs

@@ -45,31 +45,36 @@ public override void Action(IEvent ev, IProcessContext context)
 
             object syncObject = null;
 
-            lock (_locksAccess)
+            try
             {
-                if (!Locks.ContainsKey(lockValue))
+                lock (_locksAccess)
                 {
-                    Locks.Add(lockValue, new object());
-                }
+                    if (!Locks.ContainsKey(lockValue))
+                    {
+                        Locks.Add(lockValue, new object());
+                    }
 
-                syncObject = Locks[lockValue];
-            }
+                    syncObject = Locks[lockValue];
+                }
 
-            lock (syncObject)
-            {
-                foreach (IProcessBehaviour behaviour in _block.Where(behaviour => behaviour.Condition(ev, context)))
+                lock (syncObject)
                 {
-                    ProcessContext.PreAction?.Invoke(behaviour, new ActionEventArgs(context: context, ev: ev));
-                    behaviour.Action(ev, context);
-                    ProcessContext.PostAction?.Invoke(behaviour, new ActionEventArgs(context: context, ev: ev));
+                    foreach (IProcessBehaviour behaviour in _block.Where(behaviour => behaviour.Condition(ev, context)))
+                    {
+                        ProcessContext.PreAction?.Invoke(behaviour, new ActionEventArgs(context: context, ev: ev));
+                        behaviour.Action(ev, context);
+                        ProcessContext.PostAction?.Invoke(behaviour, new ActionEventArgs(context: context, ev: ev));
+                    }
                 }
             }
-
-            lock (_locksAccess)
+            finally
             {
-                if (Locks.ContainsKey(lockValue))
+                lock (_locksAccess)
                 {
-                    Locks.Remove(lockValue);
+                    if (Locks.ContainsKey(lockValue))
+                    {
+                        Locks.Remove(lockValue);
+                    }
                 }
             }
         }