并行运行两个异步任务并在.NET 4.5中收集结果

Question

并行运行两个异步任务并在.NET 4.5中收集结果

我已经尝试了一段时间来获得我认为可以简单地使用.NET 4.5的东西

我想同时启动两个长时间运行的任务，并
以最佳的C＃4.5（RTM）方式收集结果

以下作品，但我不喜欢它，因为：

• 我想Sleep成为一个异步方法，所以它可以是await其他方法

• 它看起来很笨拙 Task.Run()

• 我认为这甚至根本不使用任何新的语言功能！

工作代码：

public static void Go(){
    Console.WriteLine("Starting");

    var task1 = Task.Run(() => Sleep(5000));    
    var task2 = Task.Run(() => Sleep(3000));

    int totalSlept = task1.Result + task2.Result;

    Console.WriteLine("Slept for a total of " + totalSlept + " ms");}private static int Sleep(int ms){
    Console.WriteLine("Sleeping for " + ms);
    Thread.Sleep(ms);
    Console.WriteLine("Sleeping for " + ms + " FINISHED");
    return ms;}

非工作代码：

更新：这实际上是有效的，并且是正确的方法，唯一的问题是 Thread.Sleep

此代码不起作用，因为调用Sleep(5000)立即启动任务运行，因此Sleep(1000)在完成之前不会运行。这是真的，即使Sleep是async，我不是太快使用await或打电话.Result。

我想也许有一种方法可以Task<T>通过调用方法来获得非运行，async这样我就可以调用Start()这两个任务，但我无法弄清楚如何Task<T>通过调用异步方法来获取。

public static void Go(){
    Console.WriteLine("Starting");

    var task1 = Sleep(5000);    // blocks
    var task2 = Sleep(1000);

    int totalSlept = task1.Result + task2.Result;

    Console.WriteLine("Slept for " + totalSlept + " ms");}private static async Task<int> Sleep(int ms){
    Console.WriteLine("Sleeping for " + ms);
    Thread.Sleep(ms);
    return ms;}

Answer 1

async Task<int> LongTask1() { ... }async Task<int> LongTask2() { ... }...{&nbsp; &nbsp;Task<int> t1 = LongTask1();&nbsp; &nbsp;Task<int> t2 = LongTask2();&nbsp; &nbsp;await Task.WhenAll(t1,t2);&nbsp; &nbsp;//now we have t1.Result and t2.Result}

Answer 2

虽然你的Sleep方法是异步的，但Thread.Sleep不是。异步的整个想法是重用单个线程，而不是启动多个线程。因为您已使用对Thread.Sleep的同步调用阻止，所以它无法正常工作。我假设这Thread.Sleep是你想要做的简化。您的实际实现可以编码为异步方法吗？如果您确实需要运行多个同步阻塞调用，请查看我认为的其他地方！