erge

Step.Tasks/ThreadsHandler.cs

@@ -29,6 +29,7 @@ namespace Step.Core
             };
     private volatile static List<Thread> RunningThreadsList = new List<Thread>();
     internal volatile static Dictionary<String, String> RunningThreadStatus = new Dictionary<String, String>();
+    private static Thread StatThread;
 
     public static void Start()
     {
@@ -37,8 +38,8 @@ namespace Step.Core
 
     public static void StartWorkers()
     {
-
-      RunningThreadStatus.Clear();
+      lock (RunningThreadStatus)
+        RunningThreadStatus.Clear();
 
       // For each function run in the list a thread
       ThreadFunctionsList.ForEach(threadFunction =>
@@ -52,11 +53,12 @@ namespace Step.Core
         lock (RunningThreadsList)
           RunningThreadsList.Add(t);
 
-        
-        RunningThreadStatus.Add(threadFunction.Method.Name, "---");
+        lock (RunningThreadStatus)
+          if (!RunningThreadStatus.ContainsKey(threadFunction.Method.Name))
+            RunningThreadStatus.Add(threadFunction.Method.Name, "---");
       });
 
-      MessageServices.Current.Publish(SEND_THREADS_STATUS, null, RunningThreadStatus);
+      MessageServices.Current.Publish(MVVM_NC_THREADS, null, RunningThreadStatus);
     }
 
     public static void Stop()
@@ -73,9 +75,12 @@ namespace Step.Core
       lock (RunningThreadsList)
         RunningThreadsList.Clear();
 
-      RunningThreadStatus.Clear();
-      RunningThreadStatus.Add("TryNcConnection", "---");
-      MessageServices.Current.Publish(SEND_THREADS_STATUS, null, RunningThreadStatus);
+      lock (RunningThreadStatus)
+      {
+        RunningThreadStatus.Clear();
+        RunningThreadStatus.Add("TryNcConnection", "---");
+      }
+      MessageServices.Current.Publish(MVVM_NC_THREADS, null, RunningThreadStatus);
     }
   }
 }