如何使用异步 lambda 作为参数创建新的通用任务

Question

我需要创建一个新的通用任务，它采用异步 lambda，但不会立即启动。这就是为什么我不能使用Task.Run 并且我想实例化一个新任务。我不能这样做，因为 C# 给了我以下错误：

无法将异步 lambda 表达式转换为委托类型 Func<int>。 异步 lambda 表达式可能返回 void、Task 或 Task<T>，没有一个 可转换为Func<int>

我的代码是

Task<int> task = new Task(async () => {
    var number = await getNextNumber();
    return await algorithm(number);
});

Answer 1

我需要创建一个新的通用任务，它采用异步 lambda，但不会立即启动。这就是为什么我不能使用 Task.Run 并且我想实例化一个新任务的原因。

你应该never, ever use the Task constructor，正如我在我的博客中解释的那样。

在同步世界中，如果您想要一个可以稍后调用的对象来执行某些代码，您可以使用委托，例如 Action 或 Func<T>。

在异步世界中，如果您想要一个可以稍后调用的对象来执行某些代码，您可以使用委托。 The delegate types for asynchronous lambdas are different than the synchronous ones，正如我在博客中解释的那样；所以你可以用Func<Task>代替Action，用Func<Task<T>>代替Func<T>。

Func<Task<int>> func = async () => {
    var number = await getNextNumber();
    return await algorithm(number);
};

...

int result = await func();

Answer 2

通用任务类 Task<T> 没有将 Func<Task<T>> 作为参数的构造函数，因此您不能使用 async 关键字装饰您的 lambda。但是，非泛型任务类 Task 确实允许传入异步 lamdas。

一种解决方法是围绕Task<T> 类创建一个包装器，以使您也可以等待内部任务的方式实现这一点。

public class SuperTask<T>
{
    private Task<T> task;
    private Func<Task<T>> function;
    public SuperTask(Func<Task<T>> function)
    {
        this.function = function;
    }
    public SuperTask<T> Start()
    {
        task = function();
        return this;
    }
    public Task<T> AsTask() {
        return task;
    }
}

// And you can test it like so
SuperTask<int> testCase = new SuperTask<int>(async ()=> {
   await Task.Delay(1000); 
   return 0;
});
int number = await testCase.Start().AsTask();

Answer 3

这个方法怎么样：

Task<int> task = new Task<int>(() =>
    getNextNumber()
        .ContinueWith(t => algorithm(t.Result))
        .Unwrap()
        .Result
);

好旧的ContinueWith 加上Unwrap。

它看起来很难看，但它应该可以工作。