Changeset 16140 for branches/2817-BinPackingSpeedup/HeuristicLab.Optimization/3.3/MetaOptimizers/Experiment.cs
- Timestamp:
- 09/14/18 11:36:59 (6 years ago)
- Location:
- branches/2817-BinPackingSpeedup
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/2817-BinPackingSpeedup
- Property svn:mergeinfo changed
-
branches/2817-BinPackingSpeedup/HeuristicLab.Optimization
- Property svn:mergeinfo changed
-
branches/2817-BinPackingSpeedup/HeuristicLab.Optimization/3.3/MetaOptimizers/Experiment.cs
r15287 r16140 1 1 #region License Information 2 2 /* HeuristicLab 3 * Copyright (C) 2002-201 6Heuristic and Evolutionary Algorithms Laboratory (HEAL)3 * Copyright (C) 2002-2018 Heuristic and Evolutionary Algorithms Laboratory (HEAL) 4 4 * 5 5 * This file is part of HeuristicLab. … … 97 97 } 98 98 99 [Storable] 100 private int numberOfWorkers = 1; 101 public int NumberOfWorkers { 102 get { return numberOfWorkers; } 103 set { 104 if (value < 1) throw new ArgumentException("Number of Workers must not be lower than one."); 105 numberOfWorkers = value; 106 } 107 } 108 99 109 public IEnumerable<IOptimizer> NestedOptimizers { 100 110 get { … … 111 121 private bool experimentStarted = false; 112 122 private bool experimentStopped = false; 123 124 // track already started optimizers (.StartAsync does not set the executionstate immediately) 125 // and to avoid restarting optimizers that were manually paused/stopped by the user 126 private readonly IDictionary<IOptimizer, Task> startedOptimizers = new Dictionary<IOptimizer, Task>(); 127 private IEnumerable<IOptimizer> StartableOptimizers { 128 get { 129 return Optimizers 130 .Where(x => x.ExecutionState == ExecutionState.Prepared || x.ExecutionState == ExecutionState.Paused) 131 .Where(o => !startedOptimizers.ContainsKey(o)); // all startable optimizers that were not startet yet 132 } 133 } 113 134 114 135 public Experiment() … … 154 175 experimentStarted = original.experimentStarted; 155 176 experimentStopped = original.experimentStopped; 177 numberOfWorkers = original.numberOfWorkers; 156 178 Initialize(); 157 179 } … … 191 213 if ((ExecutionState != ExecutionState.Prepared) && (ExecutionState != ExecutionState.Paused)) 192 214 throw new InvalidOperationException(string.Format("Start not allowed in execution state \"{0}\".", ExecutionState)); 193 if (Optimizers.Count == 0) return; 215 216 startedOptimizers.Clear(); 217 if (!StartableOptimizers.Any()) return; 194 218 195 219 experimentStarted = true; 196 220 experimentStopped = false; 197 IOptimizer optimizer; 198 while ((optimizer = Optimizers.FirstOrDefault(x => (x.ExecutionState == ExecutionState.Prepared) || (x.ExecutionState == ExecutionState.Paused))) != null) { 199 // a race-condition may occur when the optimizer has changed the state by itself in the meantime 200 try { optimizer.Start(cancellationToken); } catch (InvalidOperationException) { } 201 if (ExecutionState == ExecutionState.Paused || ExecutionState == ExecutionState.Stopped) break; 221 222 using (var availableWorkers = new SemaphoreSlim(NumberOfWorkers, NumberOfWorkers)) { 223 while (StartableOptimizers.Any()) { 224 try { 225 availableWorkers.Wait(cancellationToken); 226 var optimizer = StartableOptimizers.FirstOrDefault(); 227 if (experimentStopped || !experimentStarted || optimizer == null) break; 228 229 var startedTask = optimizer.StartAsync(cancellationToken).ContinueWith(async t => { 230 availableWorkers.Release(); // is guaranteed to be not disposed yet because Task.WaitAll blocks before the end of the using 231 await t; // trigger a potential exception on the optimizerTask 232 }); 233 startedOptimizers.Add(optimizer, startedTask.Unwrap()); // unwrap task because lambda of .ContinueWith is async 234 } catch (InvalidOperationException) { } catch (OperationCanceledException) { } 235 } 236 237 Task.WaitAll(startedOptimizers.Values.ToArray()); // retrieve exeptions of the asyncrounously started optimizer 202 238 } 203 239 } … … 215 251 foreach (IOptimizer optimizer in Optimizers.Where(x => x.ExecutionState == ExecutionState.Started)) { 216 252 // a race-condition may occur when the optimizer has changed the state by itself in the meantime 217 try { optimizer.Pause(); } catch (InvalidOperationException) { } 253 try { optimizer.Pause(); } catch (InvalidOperationException) { } catch (NotSupportedException) { } 218 254 } 219 255 } … … 253 289 public event EventHandler Prepared; 254 290 private void OnPrepared() { 291 if (ExecutionState == ExecutionState.Prepared) return; 255 292 ExecutionState = ExecutionState.Prepared; 256 293 EventHandler handler = Prepared; … … 259 296 public event EventHandler Started; 260 297 private void OnStarted() { 298 if (ExecutionState == ExecutionState.Started) return; 261 299 ExecutionState = ExecutionState.Started; 262 300 EventHandler handler = Started; … … 265 303 public event EventHandler Paused; 266 304 private void OnPaused() { 305 if (ExecutionState == ExecutionState.Paused) return; 267 306 ExecutionState = ExecutionState.Paused; 268 307 EventHandler handler = Paused; … … 271 310 public event EventHandler Stopped; 272 311 private void OnStopped() { 312 if (ExecutionState == ExecutionState.Stopped) return; 273 313 ExecutionState = ExecutionState.Stopped; 274 314 EventHandler handler = Stopped; … … 367 407 } 368 408 private void optimizer_Paused(object sender, EventArgs e) { 369 lock (locker) 370 if (Optimizers.All(x => x.ExecutionState != ExecutionState.Started)) OnPaused(); 409 UpdateExecutionState(); 371 410 } 372 411 private void optimizer_Prepared(object sender, EventArgs e) { 373 lock (locker) 374 if (Optimizers.All(x => x.ExecutionState == ExecutionState.Prepared)) OnPrepared(); 412 UpdateExecutionState(); 375 413 } 376 414 private void optimizer_Started(object sender, EventArgs e) { … … 379 417 } 380 418 private void optimizer_Stopped(object sender, EventArgs e) { 419 UpdateExecutionState(); 420 } 421 private void UpdateExecutionState() { 422 // Execution states of the Experiment are determined using the following _basic_ rules: 423 // if any Optimizer is Started => Experiment is Started (2. if) 424 // if any Optimizer is Paused => Experiment is Paused (3. if) 425 // if any Optimizer is Prepared => Experiment is Prepared (5. if) 426 // else (all Optimizer are Stopped) => Experiment is Stopped (6. if) 427 // Additional there are two extra rules: 428 // if the Experiment is running and there are still optimizers that can be started => keep the Experiment Running (1. if) 429 // if experiment-stop is pending: Stop Experiment even if there are still Prepared Optimizer (4. if) 430 381 431 lock (locker) { 382 if (experimentStopped) { 383 if (Optimizers.All(x => (x.ExecutionState == ExecutionState.Stopped) || (x.ExecutionState == ExecutionState.Prepared))) OnStopped(); 384 } else { 385 if (experimentStarted && Optimizers.Any(x => (x.ExecutionState == ExecutionState.Prepared) || (x.ExecutionState == ExecutionState.Paused))) return; 386 else if (Optimizers.All(x => x.ExecutionState == ExecutionState.Stopped)) OnStopped(); 387 else if (Optimizers.Any(x => (x.ExecutionState == ExecutionState.Prepared) || (x.ExecutionState == ExecutionState.Paused)) && Optimizers.All(o => o.ExecutionState != ExecutionState.Started)) OnPaused(); 388 } 389 } 390 } 432 // 1. experiment is running & further startable optimizers are available => continue executing 433 if (experimentStarted && StartableOptimizers.Any()) 434 return; 435 436 // 2. any optimizer is running => continue executing 437 if (Optimizers.Any(x => x.ExecutionState == ExecutionState.Started)) 438 return; 439 440 experimentStarted = false; 441 // 3. any optimizer is paused => experiment paused 442 if (Optimizers.Any(x => x.ExecutionState == ExecutionState.Paused)) 443 OnPaused(); 444 445 // 4. stop pending & all optimizers either stopped or prepared => experiment stopped 446 else if (experimentStopped) 447 OnStopped(); 448 449 // 5. any optimizer prepared => experiment prepared 450 else if (Optimizers.Any(x => x.ExecutionState == ExecutionState.Prepared)) 451 OnPrepared(); 452 453 // 6. (else) all optimizers stopped 454 else 455 OnStopped(); 456 } 457 } 458 391 459 private void optimizer_Runs_CollectionReset(object sender, CollectionItemsChangedEventArgs<IRun> e) { 392 460 lock (runsLocker) {
Note: See TracChangeset
for help on using the changeset viewer.