Changeset 6402 for branches/MPI

Timestamp:

06/09/11 15:54:37 (13 years ago)

Author:

svonolfe

Message:

Improved efficiency of algorithm execution in the MPI environment (#1542)

File:

• branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/Program.cs (modified) (4 diffs)

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/Program.cs

@@ -35 +35 @@
 namespace HeuristicLab.MPIAlgorithmRunner {
   class Program {
-    EventWaitHandle waitHandle = new EventWaitHandle(false, EventResetMode.ManualReset);
-
     private static void SetJobStatus(string address) {
       Console.WriteLine("Started service... at " + address);
@@ -124 +122 @@
     }
 
+    private EventWaitHandle waitHandle;
+
     public void StartAlgorithm(MPI.Communicator communicator) {
       IAlgorithm alg = communicator.Receive<MPITransportWrapper<IAlgorithm>>(0, 0).InnerItem;
@@ -130 +130 @@
       Console.WriteLine("Starting algorithm...");
 
-      alg.Stopped += new EventHandler(algorithm_Stopped);
-      waitHandle.Reset();
-
       alg.Prepare(true);
+      waitHandle = new EventWaitHandle(false, EventResetMode.ManualReset);
+      alg.Started += new EventHandler(alg_Started);
       alg.Start();
 
-      Timer t = new Timer(delegate(object state) {
-        if (alg.ExecutionState == ExecutionState.Started) {
-          Console.WriteLine("Pausing alg...");
-          alg.Pause();
+      waitHandle.WaitOne();
 
-          while (alg.ExecutionState != ExecutionState.Paused) {
-            Thread.Sleep(100);
-          }
+      alg.Started -= new EventHandler(alg_Started);
 
-          communicator.Send<MPITransportWrapper<ResultCollection>>(
-            new MPITransportWrapper<ResultCollection>(alg.Results), 0, 1);
+      while (alg.ExecutionState != ExecutionState.Stopped) {
+        Console.WriteLine("Pausing alg...");
+        alg.Pause();
 
-          Console.WriteLine("Sending update...");
+        while (alg.ExecutionState == ExecutionState.Started) {
+          Thread.Sleep(100);
+        }
 
-          Console.WriteLine("Resuming alg...");
+        communicator.Send<MPITransportWrapper<ResultCollection>>(
+          new MPITransportWrapper<ResultCollection>(alg.Results), 0, 1);
+
+        Console.WriteLine("Sending update...");
+
+        Console.WriteLine("Resuming alg...");
+        if (alg.ExecutionState == ExecutionState.Paused)
           alg.Start();
-        }
-      }, null, updateInterval, updateInterval);
-
-      waitHandle.WaitOne();
+        Thread.Sleep(updateInterval);
+      }
 
       communicator.Send<int>(communicator.Rank, 0, 2);
@@ -162 +163 @@
     }
 
-    void algorithm_Stopped(object sender, EventArgs e) {
+    void alg_Started(object sender, EventArgs e) {
       waitHandle.Set();
     }