过早调用的 IAsyncAction OnDone 事件处理程序

本文关键字：OnDone 事件处理 程序 IAsyncAction 调用 | 更新日期: 2023-09-27 18:35:31

我的应用程序中发生了一些奇怪的事情，我无法理解它。我使用 ThreadPool 类为网络通信创建了一个后台任务。在此任务中，我异步调用一些方法。原因是有时Microsoft不提供同步方法（例如，没有方法DatagramSocket.Connect，所以我必须使用方法DatagramSocket.ConnectAsync）。但是因为我需要同步调用这些方法，所以我必须使用关键字"await"并将该方法标记为"async"。当我这样做时，过早地调用了在事件处理程序启动中创建Button_Click后台任务的事件处理程序。当后台任务真正完成其作业时（例如，通过在手动将执行指针移动到 UdpSend 方法末尾时中断调试器中的执行），不会调用 OnCompleted 事件处理程序。这正常吗？我错过了什么重要的东西吗？

/// <summary>
/// An empty page that can be used on its own or navigated to within a Frame.
/// </summary>
public sealed partial class MainPage : Page
{
   IAsyncAction work;
   public MainPage()
   {
      this.InitializeComponent();
   }
   private void Button_Click(object sender, RoutedEventArgs e)
   {
      if (work == null)
      {
         ButtonStart.Content = "Stop UDP test";
         work = ThreadPool.RunAsync(UdpSend);
         work.Completed = OnUdpSendFinish;
      }
      else
      {
         work.Cancel();
      }
   }
   private async void UdpSend(IAsyncAction work)
   {
      DatagramSocket socket = new DatagramSocket();
      socket.MessageReceived += Socket_MessageReceived;
      HostName host_name = new HostName("10.0.0.2");
      await socket.ConnectAsync(host_name, "1234");
      DataWriter writer = new DataWriter(socket.OutputStream);
      uint data = 0;
      int payload_size = 512;
      int payload_len = payload_size / sizeof(uint);
      while (work.Status != AsyncStatus.Canceled)
      {
         for (int i = 0; i < payload_len; i++)
         {
            writer.WriteUInt32(data++);
         }
         await writer.StoreAsync();
      }
   }
   private void Socket_MessageReceived(DatagramSocket sender, DatagramSocketMessageReceivedEventArgs args)
   {
      throw new System.NotImplementedException();
   }
   private async void OnUdpSendFinish(IAsyncAction asyncInfo, AsyncStatus asyncStatus)
   {
      await CoreApplication.MainView.CoreWindow.Dispatcher.RunAsync(CoreDispatcherPriority.Normal,
          () =>
          {
             ButtonStart.Content = "Start UDP test";
          });
      work = null;
   }
}

过早调用的 IAsyncAction OnDone 事件处理程序

这是因为 await 关键字的工作方式。为了可读性，它允许您在同一方法中编写所有代码，但实际上该方法一分为二。让我们举一个简单的例子：

private async void Example()
{
    DoSomething();
    await AsyncCall();
    DoSomethingElse();
}

编译后，该方法被重写为类似的东西（它要复杂得多）：

private void Example()
{
    DoSomething();
    AsyncCall();
}
private void ExampleContinuation()
{
    DoSomethingElse();
}

方法的执行方式取决于它在哪个上下文上运行。在您的情况下，由于您已经使用了线程池，因此Example在您创建的任务（您的IAsyncAction）中运行。AsyncCall 后，Example 方法返回，因此将触发Completed事件。只有这样，运行时才会从线程池中旋转一个新线程并使用它来运行ExampleContinuation 。

我的解决方法可能是使用Task.Run而不是直接使用线程池。 Task.Run还将使用覆盖下的线程池，但与所有水管工一起处理这些极端情况：

private Task work;
private void Button_Click(object sender, RoutedEventArgs e)
{
   if (work == null)
   {
      ButtonStart.Content = "Stop UDP test";
      work = Task.Run(UdpSend);
      work.ContinueWith(_ => OnUdpSendFinish());
   }
   else
   {
      work.Cancel();
   }
}

然后更改"UdpSend"方法的返回类型（它应该与方法的内容无关，但它指示应等待调用的任务）：

private async Task UdpSend(IAsyncAction work)

最后，更改Completed处理程序的签名：

private async void OnUdpSendFinish()

你完了;)

相关文章：