如何将任务结果传递给不使用延续的其他任务

Question

在func 类型中定义了不同数量的任务，因此可以定义任务，但不能自动启动。例如说：

Func<Task> task1Func = () => DoTask1Async();

以这种方式定义的一些任务返回值。我需要一种方法来‘传递’这些任务的结果到后续任务的参数，以同样的方式定义。所以，我想写：

Func<Task> task2Func = () => DoTask2Async(task1Func.Invoke().Result));

Func<Task> funcTasks = () => DoTask1Async().ContinueWith(t => DoTask2Async(t.Result));

任务按定义的顺序处理，每个任务在处理下一个任务之前完成。任务的结果仅用于后续任务。

在使用task1func.invoke().result响应对可运行代码的请求时，如下所示。创建一个新的WPF项目，并将一个按钮添加到默认网格中。然后清除mainWindow.xaml.cs文件并粘贴到下面的内容中。这是最接近我的真实项目的代码，同时删去了所有与问题无关的东西。

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Windows;

namespace WpfApplication2
{

/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
    public MainWindow()
    {
        InitializeComponent();
    }

    private async void Button_Click(object sender, RoutedEventArgs e)
    {
        // Declare first task that returns a result
        Func<Task<int>> deferredTask1 = () => DoTask1Async();
        // Declare second task using result of first.
        // BUT this isn't good as it calls deferredTask1 AGAIN, so need another approach.
        Func<Task> deferredTask2 = () => DoTask2Async(deferredTask1.Invoke().Result);

        var item1 = new MyItem() { MyDeferredTask = deferredTask1 };
        var item2 = new MyItem() { MyDeferredTask = deferredTask2 };

        List<MyItem> items = new List<MyItem>();

        items.Add(item1);
        items.Add(item2);

        await DoTasksAsync(items);

    }

    public static async Task<int> DoTask1Async()
    {
        return await Task<int>.Run(() => { return 3000; });
    }

    public static async Task DoTask2Async(int delay)
    {
        await Task.Delay(delay);
    }

    private async Task DoTasksAsync(IEnumerable<MyItem> items)
    {
        foreach (var item in items)
        {
            await item.MyDeferredTask();
        }
    }

    private class MyItem
    {
        public Func<Task> MyDeferredTask { get; set; }
    }
}
}

Answer 1

使用Microsoft的Reactive框架，您可以这样做：

var query =
    from r1 in Observable.FromAsync(() => DoTask1Async())
    from r2 in Observable.FromAsync(() => DoTask2Async(r1))
    select new { r1, r2 };

await query;