使用Task.Run获取返回值

Question

我有以下代码：

public static async Task<string> Start(IProgress<ProcessTaskAsyncExProgress> progress)
{
    const int total = 10;
    for (var i = 0; i <= total; i++)
    {
        await Task.Run(() => RunLongTask(i.ToString(CultureInfo.InvariantCulture)));
        if (progress != null)
        {
            var args = new ProcessTaskAsyncExProgress
            {
                ProgressPercentage = (int)(i / (double)total * 100.0),
                Text = "processing " + i
            };
            progress.Report(args);
        }
    }
    return "Done";
}

private static string RunLongTask(string taskName)
{
    Task.Delay(300);
    return taskName + "Completed!";
}

我该如何从这行代码中获取RunLongTask的字符串值：await Task.Run(() => RunLongTask(i.ToString(CultureInfo.InvariantCulture)));？请注意，以下是我尝试过的方法：

var val = await Task.Run(() => RunLongTask(i.ToString(CultureInfo.InvariantCulture))).Result;

但是我收到一个错误，提示“字符串不可等待”。

- Null Reference

Answer 1

移除末尾的Result。当你await时，将从可等待方法中获得Result。

var val = await Task.Run(() => RunLongTask(i.ToString(CultureInfo.InvariantCulture)));

- Haris Hasan

---

如果调用方法不能是异步的，那么如何检索返回值？ - Paul McCarthy

Answer 2

这不是对旧问题的直接回答，但对于其他正在搜索的人可能有帮助：

通常情况下，您不应该这样做，但有时候您需要匹配库API，以便使用以下的包装函数：

private async Task<string> WrapSomeMethod(string someParam)
{
    //adding .ConfigureAwait(false) may NOT be what you want but google it.
    return await Task.Run(() => SomeObj.SomeMethodAsync(someParam)).ConfigureAwait(false);
}

然后像下面这样使用.Result来调用它：

string blah = WrapSomeMethod(someParam).Result;

- Darren

---

不建议使用.Result，因为它可能会导致死锁。详见链接：https://dev59.com/tmUp5IYBdhLWcg3w1aB7。 - Gabriel Morin

@GabrielMorin 是的，“通常情况下”你不应该这样做，大约99%的时间都是如此。 - Darren

Answer 3

虚函数允许您在派生类中重写该函数。任务按顺序逐个运行。Task.CompletedTask表示函数已完成。

public class BaseTest
{
    public virtual Task LoadDataAsync(ITestOutputHelper output) {
        for (int i = 0; i < Math.Pow(10, 5); i++)
        {
            output.WriteLine("Base {0}", i);
        }
        return Task.CompletedTask; 
    }
}
public class DerivedTest : BaseTest
{
    public override Task LoadDataAsync(ITestOutputHelper output)
    {
        for (int i = 0; i < Math.Pow(10, 6); i++)
        {
            output.WriteLine("Derived {0}", i);
        }
        return Task.CompletedTask;
    }
}


 [Fact]
    public async Task TestVirtualTask()
    {
        BaseTest parent_obj = new BaseTest();
        DerivedTest obj = new DerivedTest();
        List<Task> tasks = new List<Task>();
        tasks.Add(obj.LoadDataAsync(output));
        tasks.Add(parent_obj.LoadDataAsync(output));

        Task.WaitAll(tasks.ToArray());
        Assert.True(true);
    }

您可以添加异步函数并等待 task.run。这增加了措辞而不增加功能。

      public virtual async Task LoadDataAsync(ITestOutputHelper output) {
await Task.Run(() =>
            {
                for (int i = 0; i < Math.Pow(10, 6); i++)
                {
                    output.WriteLine("Derived {0}", i);
                }
                return;
            });
 }

- Golden Lion