带有异步 lambda 表达式的异步方法

Question

我有一个内部带有异步调用的 lambda 表达式

public async Task UploadFile(string id)
{
    Progress<double> progress = new Progress<double>(async x =>
    {
        await Clients.Client(id).SendAsync("FTPUploadProgress", x);
    });
    await client.DownloadFileAsync(localPath, remotePath, true, FluentFTP.FtpVerify.Retry, progress);
}

我想在进度改变时调用 async 方法。

我收到以下警告：

此异步方法缺少“等待”运算符，将同步运行。 考虑使用 'await' 运算符来等待非阻塞 API 调用

我怎样才能使这个方法异步？

我应该用 System.Action<T> 类重写 lambda 吗？

Answer 1

使用事件处理程序并在进度操作中引发它。事件处理程序将允许异步调用。

幸运的是，Progress<T> 有一个您可以订阅的 ProgressChanged 事件。

根据原始问题中提供的代码查看以下示例

public async Task UploadFile(string id) {
    EventHandler<double> handler = null;
    //creating the handler inline for compactness
    handler = async (sender, value) => {
        //send message to client asynchronously
        await Clients.Client(id).SendAsync("FTPUploadProgress", value);
    };
    var progress = new Progress<double>();
    progress.ProgressChanged += handler;//subscribe to ProgressChanged event

    //use the progress as you normally would
    await client.DownloadFileAsync(localPath, remotePath, true, FluentFTP.FtpVerify.Retry, progress);

    //unsubscribe when done 
    progress.ProgressChanged -= handler;
}

所以现在当报告进度时，事件处理程序可以进行异步调用。

参考Async/Await - Best Practices in Asynchronous Programming

另一种选择是创建您自己的 IProgress<T> 实现，该实现采用允许异步调用的 Func<Task<T>>，但这可能有点矫枉过正。

Answer 2

我认为您误解了 Progress<T> 类的用法。编译器抱怨说，您的方法 UploadFile 缺少 await 运算符。当你的 lambda 被调用时，它会异步执行。

下面是一个简短的总结如何使用IProgressyT>接口：

如果您有一个应该支持报告进度的方法，它可以将IProgress<T> 作为参数并通过此对象传达其端口。它不执行受监控的操作。每次在 Progress<T> 上调用 Report() 方法时，都会执行您提供的 Lambda。此 Lambda 通常用于更新 UI。

这是一个例子。

public async Task DoStuff(IProgress<double> progress = null)
{
     for(int i = 0; i < 100; ++i)
     {
         await Task.Delay(500);
         progress?.Report((double)(i +1) / 100);
     }
}


// somewhere else in your code
public void StartProgress(){
    var progress = new Progress(p => Console.WriteLine($"Progress {p}"));
    DoStuff(progress);  
}