0

这是我尝试使用的具有异步响应的 3 层应用程序模型：

  • 图形用户界面
  • 后端
  • 远程服务器

图形用户界面：

private async void readFloatButton_Click(object sender, RoutedEventArgs e)
{
  FloatValueLabel.Content = (await srvProtocol.ReadFloat("ReadFloatX")).ToString();
}

后端（使用内部变量binReader和connection） 

public Task<float> ReadFloat(string cmd)
 {
   var tcs1 = new TaskCompletionSource<float>();
   var floatTask = tcs1.Task;    
   RegisterResponse(cmd, 
                     () =>
                     tcs1.SetResult(_binReader.ReadSingle());
                    );
   // We are ready: now send request to server(assuming that this is a quick operation)
   connection.Send(cmd); 
   return floatTask;
 }

这里 RegisterResponse 将 <Key, Action> 对添加到一些线程安全的字典中。另一个工作线程从网络流消息（消息头）中读取，并根据消息头中的字符串 cmd 调用操作。

现在的问题：

  • 当我需要订阅 GUI 元素以进行定期更新（不是单个回调）时，是否可以达到相同的简洁程度？
4

1 回答 1

1

好吧，你可以把你拥有的东西放入一个循环中，例如：

private async void StartReading()
{
  while (true)
  {
    FloatValueLabel.Content = (await srvProtocol.ReadFloat("ReadFloatX")).ToString();
    await Task.Delay(1000);
  }
}

虽然我个人不喜欢“无限异步”循环。停止循环的唯一方法是抛出异常（错误或取消）。

Rx 库更适合订阅。它允许高度“简洁”，但学习曲线更陡峭。

您还可以将所有订阅逻辑包装到模型/视图模型中。这在处理“更新”相同的概念值时特别有意义。在这种情况下，StartReading将是您的模型/视图模型上的一个方法。它将使用async（用于无限异步循环）或ObserveOn（用于 Rx）将更新带到 UI 线程，然后使用标准INotifyPropertyChanged/ObservableCollection间接更新 UI。

于 2012-01-02T19:35:55.073 回答