Changeset 734

Timestamp:

11/11/08 17:50:43 (15 years ago)

Author:

kgrading

Message:

implemented a threadsafe MessageQueue (#347)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Client.Common/HeuristicLab.Hive.Client.Common.csproj (modified) (1 diff)
• HeuristicLab.Hive.Client.Common/MessageContainer.cs (added)
• HeuristicLab.Hive.Client.Common/MessageQueue.cs (added)
• HeuristicLab.Hive.Client.Core/CoreApplication.cs (modified) (1 diff)
• HeuristicLab.Hive.Client.Core/Heartbeat.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.Hive.Client.Common/HeuristicLab.Hive.Client.Common.csproj

@@ -67 +67 @@
     <Compile Include="CommonPlugin.cs" />
     <Compile Include="Logging.cs" />
+    <Compile Include="MessageContainer.cs" />
+    <Compile Include="MessageQueue.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>

trunk/sources/HeuristicLab.Hive.Client.Core/CoreApplication.cs

@@ -14 +14 @@
     public override void Run() {
  
-      Logging.getInstance().Info(this.Name, "Info Message");
-      Logging.getInstance().Error(this.Name, "Error Message");
-      Logging.getInstance().Error(this.Name, "Exception Message", new Exception("Exception"));
+      //Logging.getInstance().Info(this.Name, "Info Message");
+      //Logging.getInstance().Error(this.Name, "Error Message");
+      //Logging.getInstance().Error(this.Name, "Exception Message", new Exception("Exception"));
       
       Heartbeat beat = new Heartbeat();
       beat.Interval = 1000;
       beat.StartHeartbeat();
-      DoRubbish();
-      Console.WriteLine("done");
-      Thread.Sleep(99999);
-    }
+      MessageQueue queue = MessageQueue.GetInstance();
+      
+      while (true) {
+        MessageContainer container = queue.GetMessage();
+        Console.WriteLine(container.Message.ToString());
+      }
 
-    private void DoRubbish() {
-      for (int w = 0; w < 20000000; w++)
-        for (int x = 0; x < 20000000; x++)
-          for (int y = 0; y < 20000000; y++) {
-          }
-
+      
     }
   }

trunk/sources/HeuristicLab.Hive.Client.Core/Heartbeat.cs

@@ -4 +4 @@
 using System.Text;
 using System.Timers;
+using HeuristicLab.Hive.Client.Common;
 
 namespace HeuristicLab.Hive.Client.Core {
@@ -24 +25 @@
       heartbeatTimer.AutoReset = true;
       heartbeatTimer.Elapsed += new ElapsedEventHandler(heartbeatTimer_Elapsed);
-      heartbeatTimer.Start();            
+      heartbeatTimer.Start();               
     }
 
     void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {
       Console.WriteLine("tick");
+      MessageQueue.GetInstance().AddMessage(MessageQueue.MessageType.FetchJob);
     }