Changeset 7566 for branches/MPI/HeuristicLab.MPIAlgorithmRunner

Timestamp:

03/06/12 16:11:36 (13 years ago)

Author:

svonolfe

Message:

Adapted MPI operators (#1542)

Location:

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3

Files:

• HeuristicLab.MPIAlgorithmRunner-3.3.csproj (modified) (1 diff)
• Program.cs (modified) (5 diffs)

branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/HeuristicLab.MPIAlgorithmRunner-3.3.csproj

@@ -115 +115 @@
       <Private>False</Private>
     </Reference>
+    <Reference Include="HeuristicLab.Operators-3.3, Version=3.3.0.0, Culture=neutral, PublicKeyToken=ba48961d6f65dcec, processorArchitecture=MSIL" />
     <Reference Include="HeuristicLab.Optimization-3.3, Version=3.3.0.0, Culture=neutral, PublicKeyToken=ba48961d6f65dcec, processorArchitecture=MSIL">
       <HintPath>..\..\..\..\trunk\sources\bin\HeuristicLab.Optimization-3.3.dll</HintPath>

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

@@ -33 +33 @@
 using HeuristicLab.Core;
 using System.Diagnostics;
+using HeuristicLab.Common;
+using System.IO;
 
 namespace HeuristicLab.MPIAlgorithmRunner {
@@ -41 +43 @@
       if (args.Length == 2) {
         string fileName = args[0];
-        string resultName = args[1];
-
-        using (new MPI.Environment(ref args)) {
-          if (MPI.Communicator.world.Rank != 0) {
-            Program p = new Program();
-            p.StartAlgorithm(fileName, resultName + MPI.Communicator.world.Rank + ".hl");
+        int calcTime;
+        if (int.TryParse(args[1], out calcTime)) {
+         using (new MPI.Environment(ref args)) {
+            if (MPI.Communicator.world.Rank != 0) {
+              Program p = new Program();
+              p.StartAlgorithm(fileName,calcTime);
+            }
+          }                     
+        } else {
+          string resultName = args[1];
+
+          using (new MPI.Environment(ref args)) {
+            if (MPI.Communicator.world.Rank != 0) {
+              Program p = new Program();
+              p.StartAlgorithm(fileName, resultName + MPI.Communicator.world.Rank + ".hl");
+            }
           }
-        }
+        }       
       } else {
         using (new MPI.Environment(ref args)) {
@@ -192 +204 @@
       sw.Start();
 
-     /* Thread.Sleep(10000);      
-      Thread t = new Thread(delegate() {
-        while (true) {
-          if (alg.ExecutionState == Core.ExecutionState.Started) {
-            alg.Pause();
-
-            while (alg.ExecutionState == Core.ExecutionState.Started)
-              Thread.Sleep(100);
-
-            if (alg.Results.ContainsKey("Best valid Solution Distance")) {
-              Console.WriteLine("BestDistance: " + alg.Results["Best valid Solution Distance"].Value.ToString());
-            }
-
-            if (alg.Results.ContainsKey("Best valid Solution Vehicles")) {
-              Console.WriteLine("BestVehicles: " + alg.Results["Best valid Solution Vehicles"].Value.ToString());
-            }
-
-            XmlGenerator.Serialize(alg, resultName);
-            alg.Start();
+      if (MPI.Communicator.world.Rank == 1) {
+        Thread.Sleep(10000);
+        Thread t = new Thread(delegate() {
+          while (true) {
+            if (alg.ExecutionState == Core.ExecutionState.Started) {
+              alg.Pause();
+
+              while (alg.ExecutionState == Core.ExecutionState.Started)
+                Thread.Sleep(100);
+
+              if (alg.Results.ContainsKey("Best valid VRP Solution Distance")) {
+                Console.WriteLine("BestDistance: " + alg.Results["Best valid VRP Solution Distance"].Value.ToString());
+              }
+
+              if (alg.Results.ContainsKey("Best valid VRP Solution VehicleUtilization")) {
+                Console.WriteLine("BestVehicles: " + alg.Results["Best valid VRP Solution VehicleUtilization"].Value.ToString());
+              }
+
+              XmlGenerator.Serialize(alg, resultName);
+              alg.Start();
+            }
+
+            Thread.Sleep(300000);
           }
-
-          Thread.Sleep(300000);
-        }
-      });
-      t.IsBackground = true;
-      t.Start();*/
+        });
+        t.IsBackground = true;
+        t.Start();
+      }
 
       waitHandle.WaitOne();
@@ -225 +239 @@
       Console.WriteLine("TIME: " + sw.ElapsedMilliseconds + "ms");
 
-      if (alg.Results.ContainsKey("Best valid Solution Distance") && alg.Results.ContainsKey("Best valid Solution Vehicles")) {
-        Console.WriteLine("BestDistance: " + alg.Results["Best valid Solution Distance"].Value.ToString() + ", " + 
-                          "BestVehicles: " + alg.Results["Best valid Solution Vehicles"].Value.ToString());
+      if (alg.Results.ContainsKey("Best valid VRP Solution Distance") && alg.Results.ContainsKey("Best valid VRP Solution VehicleUtilization")) {
+        Console.WriteLine("BestDistance: " + alg.Results["Best valid VRP Solution Distance"].Value.ToString() + ", " +
+                          "BestVehicles: " + alg.Results["Best valid VRP Solution VehicleUtilization"].Value.ToString());
       }
 
@@ -236 +250 @@
       waitHandle.Set(); 
     }
+
+    public void StartAlgorithm(string fileName, int calculationTime) {
+      IAlgorithm alg = XmlParser.Deserialize<HeuristicLab.Optimization.IAlgorithm>(fileName);
+      IOperator breakpoint = ((alg.Parameters["Analyzer"] as IValueParameter).Value as IOperator);
+
+      waitHandle.Reset();
+
+      alg.Start();
+
+      Thread.Sleep(calculationTime);
+
+      if (alg.ExecutionState == ExecutionState.Started) {
+        waitHandle.Reset();
+        alg.Paused += new EventHandler(alg_Paused);
+        breakpoint.Breakpoint = true;
+
+        waitHandle.WaitOne();
+
+        breakpoint.Breakpoint = false;
+        alg.Paused -= new EventHandler(alg_Paused);
+      }
+
+      Mutex mutex = new Mutex(false, "ResultFile");
+      mutex.WaitOne();
+      Console.WriteLine("SERIALIZING");
+      XmlGenerator.Serialize(alg, fileName);
+      MPI.Communicator.world.Abort(0);
+    }
+
+    void alg_Paused(object sender, EventArgs e) {
+      waitHandle.Set();
+    }
   }
 }