Added time out to wait event handle objects of data manager

Author: Ahmad Noman Musleh

src/Alert/DataManager.cs

@@ -1,6 +1,7 @@
 using cAlgo.API.Alert.Models;
 using cAlgo.API.Alert.UI.Models;
 using LiteDB;
+using System;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
@@ -21,16 +22,17 @@ public static IEnumerable<AlertModel> GetAlerts()
 
             using (var eventWaitHandle = GetWaitHandle())
             {
-                eventWaitHandle.WaitOne();
-
-                using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                if (eventWaitHandle.WaitOne(TimeSpan.FromMinutes(1)))
                 {
-                    var collection = database.GetCollection<AlertModel>();
+                    using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                    {
+                        var collection = database.GetCollection<AlertModel>();
 
-                    result = collection.FindAll().ToList();
-                }
+                        result = collection.FindAll().ToList();
+                    }
 
-                eventWaitHandle.Set();
+                    eventWaitHandle.Set();
+                }
             }
 
             return result;
@@ -40,33 +42,35 @@ public static void AddAlerts(params AlertModel[] alerts)
         {
             using (var eventWaitHandle = GetWaitHandle())
             {
-                eventWaitHandle.WaitOne();
-
-                using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                if (eventWaitHandle.WaitOne(TimeSpan.FromMinutes(1)))
                 {
-                    var collection = database.GetCollection<AlertModel>();
+                    using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                    {
+                        var collection = database.GetCollection<AlertModel>();
 
-                    collection.InsertBulk(alerts);
-                }
+                        collection.InsertBulk(alerts);
+                    }
 
-                eventWaitHandle.Set();
+                    eventWaitHandle.Set();
+                }
             }
         }
 
         public static void RemoveAlerts(params AlertModel[] alerts)
         {
             using (var eventWaitHandle = GetWaitHandle())
             {
-                eventWaitHandle.WaitOne();
-
-                using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                if (eventWaitHandle.WaitOne(TimeSpan.FromMinutes(1)))
                 {
-                    var collection = database.GetCollection<AlertModel>();
+                    using (LiteDatabase database = new LiteDatabase(GetConnectionString()))
+                    {
+                        var collection = database.GetCollection<AlertModel>();
 
-                    collection.DeleteMany(iAlert => alerts.Contains(iAlert));
-                }
+                        collection.DeleteMany(iAlert => alerts.Contains(iAlert));
+                    }
 
-                eventWaitHandle.Set();
+                    eventWaitHandle.Set();
+                }
             }
         }
 

test/UITestConsole/Program.cs

@@ -10,13 +10,13 @@ private static void Main(string[] args)
         {
             var notifications = new Notifications();
 
-            notifications.ShowPopup();
+            //notifications.ShowPopup();
 
             //notifications.ShowPopup("Hour", "EURUSD", "Trend Line", "UITestConsole", 1.23452, "No comment 2", DateTimeOffset.Now);
 
             //TriggerAlerts(50, notifications);
 
-            //TestMultiThread();
+            TestMultiThread(10);
         }
 
         private static void TriggerAlerts(int number, Notifications notifications)
@@ -42,13 +42,13 @@ private static void TriggerAlerts(int number, Notifications notifications)
                     TriggeredBy = "UITestConsole"
                 };
 
-                notifications.TriggerAlert(alert);
+                notifications.ShowPopup(alert);
             }
         }
 
-        private static void TestMultiThread()
+        private static void TestMultiThread(int threadNumber)
         {
-            for (int i = 0; i < 20; i++)
+            for (int i = 1; i <= threadNumber; i++)
             {
                 int number = i;