Task.WaitAll - 不等待？

Question

我试图在任务并行库中找到Task.WaitAll(..).

我正在使用以下代码运行测试以尝试模拟两个任务,一个将比指定的等待时间(10秒)运行更长时间(10秒),一个运行时间少于指定的时间(3秒)等待的时间.指定的时间是5秒.我使用的代码如下:

Task<int>[] tasks = new Task<int>[]
{
    Task.Factory.StartNew<int>(()=>
        {
            Thread.Sleep(10000);
            return 1;
        }),
    Task.Factory.StartNew<int>(()=>
        {
            Thread.Sleep(3000);
            return 2;
        })
};

TimeSpan timeSpan = new TimeSpan(0, 0, 5);
Task.WaitAll(tasks,timeSpan);

int[] results = new int[tasks.Length];
for(int i = 0; i < tasks.Length;i++)
{
    Console.WriteLine(tasks[i].Result);
}

至于timeSpan,我也尝试直接传入5000而不是timeSpan变量,但它不起作用.我得到以下输出:

1
2

我希望只得到以下输出,因为另一个线程的执行时间超过了预期的等待时间.

1

我误解了这个,还是做错了？

Answer 1

虽然Task.Delay是您通常想要使用的(因此您不会在睡眠期间浪费线程),但您的问题实际上与此无关.

这里发生的是当你打印出结果时,你正在访问每个任务的Result属性.这会阻止任务完成,所以你在WaitAll中等待5秒,然后在打印出10秒任务的结果时再等5秒.

根据您声明的意图,您需要在访问结果之前检查任务状态,因为您的意图不是阻止它,而只是在碰巧已经完成时将其打印出来:

int[] results = new int[tasks.Length];
for (int i = 0; i < tasks.Length; i++)
{
    if (tasks[i].IsCompleted)
    {
        Console.WriteLine(tasks[i].Result);
    }
}

顺便说一句,您可以通过添加一些简单的时间检查(例如,使用秒表,这样)来显示"结果上的阻止"是原始代码中发生的情况.

Task<int>[] tasks = new Task<int>[]
{
    Task.Factory.StartNew<int>(()=>
        {
            Thread.Sleep(10000);
            return 1;
        }),
    Task.Factory.StartNew<int>(()=>
        {
            Thread.Sleep(3000);
            return 2;
        })
};

TimeSpan timeSpan = new TimeSpan(0, 0, 5);
var stopwatch = Stopwatch.StartNew();
Task.WaitAll(tasks, timeSpan);
Console.WriteLine("WaitAll took {0} seconds", stopwatch.Elapsed.TotalSeconds);

int[] results = new int[tasks.Length];
for (int i = 0; i < tasks.Length; i++)
{
    stopwatch = Stopwatch.StartNew();
    Console.WriteLine(tasks[i].Result);
    Console.WriteLine("Printing result took {0} seconds", stopwatch.Elapsed.TotalSeconds);
}

这会产生以下控制台输出:

WaitAll took 4.9996961 seconds
1
Printing result took 5.0050012 seconds
2
Printing result took 0.0004338 seconds