Changeset 2125 for trunk/sources/HeuristicLab.CEDMA.Server/3.3

Timestamp:

07/01/09 20:11:39 (15 years ago)

Author:

gkronber

Message:

Implemented a fix for #681 (GridExecuter should allow more than 64 concurrent jobs).

Location:

trunk/sources/HeuristicLab.CEDMA.Server/3.3

Files:

• ExecuterView.Designer.cs (modified) (1 diff)
• GridExecuter.cs (modified) (2 diffs)

trunk/sources/HeuristicLab.CEDMA.Server/3.3/ExecuterView.Designer.cs

@@ -54 +54 @@
       this.maxActiveJobs.Location = new System.Drawing.Point(98, 3);
       this.maxActiveJobs.Maximum = new decimal(new int[] {
-            64,
+            200,
             0,
             0,

trunk/sources/HeuristicLab.CEDMA.Server/3.3/GridExecuter.cs

@@ -83 +83 @@
             }
           }
-          // wait until any job is finished
           WaitHandle[] whArr = asyncResults.Keys.ToArray();
-          int readyHandleIndex = WaitHandle.WaitAny(whArr, WaitForFinishedJobsTimeout);
+          int readyHandleIndex = WaitAny(whArr, WaitForFinishedJobsTimeout);
           if (readyHandleIndex != WaitHandle.WaitTimeout) {
             WaitHandle readyHandle = whArr[readyHandleIndex];
@@ -113 +112 @@
     }
 
+        // wait until any job is finished
+    private int WaitAny(WaitHandle[] wh, TimeSpan WaitForFinishedJobsTimeout) {
+      if (wh.Length > 64) {
+        return WaitHandle.WaitAny(wh, WaitForFinishedJobsTimeout);
+      } else {
+        for (int i = 0; i < wh.Length; i++) {
+          if (wh[i].WaitOne(WaitForFinishedJobsTimeout)) {
+            return i;
+          }
+        }
+        return WaitHandle.WaitTimeout;
+      }
+    }
+
     public override string[] GetJobs() {
       lock (activeAlgorithms) {