Erhalten Statistik der ausgeführten Aufgaben in C#

Question

ich einfach folgenden Code haben:

var tasks = statements.Select(statement => _session.ExecuteAsync(statement)); 
var result = Task.WhenAll(tasks).Result; 
[...] 

Wie kann ich berechnen min, max, avg, usw. aller ausgeführten Aufgaben? Die Aufgabenklasse hat keine Eigenschaft wie "executedMilliseconds"

Answer 1

Mit der folgenden Erweiterungsmethode:

public static class EnumerableExtensions 
{ 
    public static IEnumerable<Task<TimedResult<TReturn>>> TimedSelect<TSource, TReturn>(
     this IEnumerable<TSource> source, 
     Func<TSource, Task<TReturn>> func) 
    { 
     if (source == null) throw new ArgumentNullException("source"); 
     if (func == null) throw new ArgumentNullException("func"); 

     return source.Select(x => 
     { 
      Stopwatch stopwatch = new Stopwatch(); 
      stopwatch.Start(); 

      Task<TReturn> task = func(x); 

      Task<TimedResult<TReturn>> timedResultTask = task 
       .ContinueWith(y => 
       { 
        stopwatch.Stop(); 

        return new TimedResult<TReturn>(task, stopwatch.Elapsed); 
       }); 

      return timedResultTask; 
     }); 
    } 
} 

public class TimedResult<T> 
{ 
    internal TimedResult(Task<T> task, TimeSpan duration) 
    { 
     Task = task; 
     Duration = duration; 
    } 

    public readonly Task<T> Task; 
    public readonly TimeSpan Duration; 
} 

Und callsite

var tasks = statements.TimedSelect(statement => _session.ExecuteAsync(statement)); 

var result = Task.WhenAll(tasks).Result; 

können Sie die Ergebnisse extrahieren, die Sie

// Whatever works (ugly, but just as an example)... 
var min = result.Select(x => x.Duration).Min(); 
var max = result.Select(x => x.Duration).Max(); 
var avg = new TimeSpan((long)result.Select(x => x.Duration.Ticks).Average()); 

Hinweis benötigen, dass dieser Pool Wartezeit beinhaltet (Zeit, die darauf wartet, dass ein Task-Thread verfügbar wird), und ist daher möglicherweise nicht korrekt.

Eine nicht-generische Variante dieser Erweiterung ist eine Übung für den Leser.

Answer 2

Sie können Aufgaben eine ContinuationTask geben, die aufgerufen wird, nachdem die Aufgabe abgeschlossen wurde. Mit diesem können Sie eine Reihe von Stoppuhren verwenden und die Fortsetzungsaufgabe verwenden, um sie einzeln zu stoppen.