使用异步而不是 Task.Run()

Question

我有以下代码：

private void btnAction_Click(object sender, RoutedEventArgs e)
{

    /** Clear the results field */
    txtResult.Text = "";

    /** Disable the button and show waiting status */
    btnAction.IsEnabled = false;
    lblStatus.Text = "Wait...";

    /** Get input from the query field */
    string input = query.Text;

    /** Run a new task */
    Task.Run(() => {

        // calling a method that takes a long time (>3s) to finish and return
        var attempt = someLibrary.doSomethingWith(input);

        // return the result to the GUI thred
        this.Dispatcher.Invoke(() =>
        {

            if (attempt.ContainsKey("success"))
            {
                if (attempt["success"] == true)
                {
                    txtResult.Text = "Success! The door is: " + (attempt["is_open"] ? "open" : "closed");
                    lblStatus.Text = "";
                }
                else
                {
                    lblStatus.Text = "Error! The service says: " + attempt["errorMessage"];
                }
            }

            else
            {
                MessageBox.Show("There was a problem getting results from web service.");
                lblStatus.Text = "";
            }

            /** Re-enable the button */
            btnAction.IsEnabled = true;

        });
    });

}

现在，我想：

• 以使用回调而不是使用Dispatcher.Invoke() 的方式编写相同的代码。
• 能够取消调用doSomething()的正在运行的任务
• 能够链接多个调用，即等待 doSomething() 并在它完成后，doAnotherThing() 与上一次调用的结果

因此我想使用异步模型来编写这个。

我该怎么办？

Answer 1

您可以将您的方法标记为async、await Task.Run，因此 continuations 在 UI 上运行，也只留下 long在其中运行（似乎受CPU限制）作业

private async void btnAction_Click(object sender, RoutedEventArgs e)
{
   btnAction.IsEnabled = false;
   txtResult.Text = "";       
   lblStatus.Text = "Wait...";

   string input = query.Text;

   // calling a method that takes a long time (>3s) to finish and return
   var attempt =  await Task.Run(() => someLibrary.doSomethingWith(input));

   if (attempt.ContainsKey("success"))
   {
      if (attempt["success"] == true)
      {
         txtResult.Text = "Success! The door is: " + (attempt["is_open"] ? "open" : "closed");
         lblStatus.Text = "";
      }
      else
      {
         lblStatus.Text = "Error! The service says: " + attempt["errorMessage"];
      }
   }  
   else
   {
      MessageBox.Show("There was a problem getting results from web service.");
      lblStatus.Text = "";
   }

   btnAction.IsEnabled = true;

}

更新

要取消任务，您可以使用 CancellationTokenSource 的实例中的 CancellationToken 并将其传递给 Task.Run 以及检查 IsCancellationRequested 的长期运行方法（如果可以）。您可以拨打CancellationTokenSource.Cancel取消

请注意，您可能希望将其包装在 try catch finally 中，然后使用 OperationCanceledException 并将您的按钮启用代码放在 finally 中

Answer 2

async 修饰符要求函数返回Task<T>（或void，在这种情况下任何等待语句都将被忽略）。这意味着使用async和使用Task.Run()是一回事，你的问题的前提没有意义。

但是，我认为您想要做的只是使用 async await 语法来避免显式调用 Task.Run()。

回调

只需创建一个返回Task的函数

async Task<T> Foo()

然后分配一个变量var bar=await Foo();

取消正在运行的任务

只需使用CancellationToken

CancellationTokenSource tokenSource = new CancellationTokenSource();

如果你用两个参数构造一个任务，第二个参数是一个取消标记：

var bar= new Task(action, tokenSource.Token)

这让你可以使用 tokenSource.Cancel();

相关链接：https://docs.microsoft.com/en-us/dotnet/api/system.threading.cancellationtoken?view=netframework-4.8

链接调用

如果您不需要定义的执行顺序，您可以使用Task.WhenAll()，否则您可以在前一个任务中或在等待代码中执行下一个任务。

Task.WhenAll():https://docs.microsoft.com/en-us/dotnet/api/system.threading.tasks.task.whenall?view=netframework-4.8#System_Threading_Tasks_Task_WhenAll_System_Collections_Generic_IEnumerable_System_Threading_Tasks_Task__