推迟启动Task <T>

Mat*_*rli 5 c# task-parallel-library async-await .net-core

我有一系列方法(具有可变数量的参数)返回一个Task,我想通过传递Task来创建一个在每个方法之前和之后执行某些操作的方法。我简化了此示例中的所有内容(删除了cancelToken,实际处理等):

public async Task<string> GetDataString()
{
    Console.WriteLine("Executing");
    return "test";
}


public async Task<T> Process<T>(Task<T> task)
{
    Console.WriteLine("Before");
    var res = await task;
    Console.WriteLine("After");
    return res;
}
Run Code Online (Sandbox Code Playgroud)

而在我的主要:

Task<string> task = GetDataString();
string result = await Process<string>(tasks);
Console.WriteLine(res);
Run Code Online (Sandbox Code Playgroud)

控制台输出是

Executing
Before
After
test
Run Code Online (Sandbox Code Playgroud)

我该怎么做才能创建任务而不实际启动它?并仅在等待之前启动它?

我设法通过创建PauseToken来做到这一点,如本文所述:https ://devblogs.microsoft.com/pfxteam/cooperatively-pausing-async-methods/ 但我想知道是否有更好的方法。

谢谢,Mattia

The*_*ias 6

您的通用ProcessAsync方法可以接受任务工厂作为参数:

public async Task<T> ProcessAsync<T>(Func<Task<T>> taskFactory)
{
    Console.WriteLine("Before");
    var res = await taskFactory();
    Console.WriteLine("After");
    return res;
}
Run Code Online (Sandbox Code Playgroud)

这样,您将在调用工厂方法时创建任务。您可以控制它的创建。

这是调用ProcessAsync方法的示例,将lambda作为工厂传递:

var result = await ProcessAsync(() => GetDataStringAsync(arg1, arg2));
Run Code Online (Sandbox Code Playgroud)

这样,您就不受限于没有参数的工厂方法。

为了完整起见,我应该提到Task对象也可以使用构造函数在冷态下创建new Task(),并在以后使用Start方法启动,但是不建议使用此方法。