Changeset 5329 for branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.ExperimentManager

Timestamp:

01/18/11 17:57:14 (14 years ago)

Author:

cneumuel

Message:

#1260

• robustified HiveEngine and HiveJobDownloader (handling of unobserved exceptions from tasks)

File:

• branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.ExperimentManager/3.3/HiveJobDownloader.cs (modified) (2 diffs)

branches/HeuristicLab.Hive-3.3/sources/HeuristicLab.Hive/HeuristicLab.Hive.ExperimentManager/3.3/HiveJobDownloader.cs

@@ -58 +58 @@
       abort = false;
       tasks = new List<Task<HiveJob>>();
+      TaskScheduler.UnobservedTaskException += new EventHandler<UnobservedTaskExceptionEventArgs>(TaskScheduler_UnobservedTaskException);
       foreach (Guid jobId in jobIds) {
         tasks.Add(Task<SerializedJob>.Factory.StartNew(
@@ -64 +65 @@
       }
     }
+
+    private void TaskScheduler_UnobservedTaskException(object sender, UnobservedTaskExceptionEventArgs e) {
+      e.SetObserved(); // evoid crash of process because task crashes. first exception found is handled in Results property
+    }
+
     // use semaphore to ensure only few concurrenct connections and few SerializedJob objects in memory
     private Semaphore downloadSemaphore = new Semaphore(2, 2);