Changeset 6401 for branches/MPI/HeuristicLab.MPIAlgorithmRunner/3.3/Program.cs

Timestamp:

06/09/11 12:52:48 (13 years ago)

Author:

svonolfe

Message:

Implemented result and algorithm streaming (#1542)

File:

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

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

@@ -77 +77 @@
           SetJobStatus(address);
 
-          ItemList<ResultCollection> results = new ItemList<ResultCollection>();
-          
           bool[] finished = new bool[clients];
           int finishedCount = 0;
 
           while (finishedCount != clients) {
+            ItemList<ResultCollection> results = new ItemList<ResultCollection>();
+
             for (int i = 0; i < clients; i++) {
               if (!finished[i]) {
@@ -105 +105 @@
 
             Console.WriteLine("Update results");
-            broker.Results = results;
+            lock (broker.resultLocker)
+              broker.Results = results;
           }
 
@@ -114 +115 @@
           broker.ExitWaitHandle.WaitOne();
           Console.WriteLine("Finished.");
+          Thread.Sleep(1000);
           service.Close();
         } else {