在C#中获取已执行任务的统计信息

Question

我有以下简单代码：

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

如何计算所有已执行任务的最小值、最大值、平均值等？任务 class 没有属性像 "executedMilliseconds"

Answer 1

你可以给任务一个ContinuationTask，这是任务完成后调用的东西。有了这个，你可以使用一堆秒表并使用延续任务来单独停止它们。

Answer 2

使用以下扩展方法：

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;
}

和调用站点

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

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

您可以提取您需要的结果

// 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());

请注意，这包括池等待时间（等待任务线程可用的时间），因此可能不准确。

此扩展的非通用变体是 reader 的练习。

在C#中获取已执行任务的统计信息

Get statistic of executed tasks in C#

c#

task

task-parallel-library