我只想说明我刚刚开始尝试使用Async,所以我对我正在做的事情的理解非常有限。
我之前使用线程从串行端口读取数据,将数据处理成要写入的数据,然后编写它。我有1个线程读取数据并将其放入缓冲区,另一个线程处理缓冲区中的数据,最后一个线程写入它。这样,如果我点击一个按钮,我就可以发送更多数据。
现在我只是想学习并确保我正在做所有事情,所以我试图从串口读取数据,并将该数据添加到多行文本框中。这是代码:
连接到串口,如果成功,调用异步的UpdateMessageBox
:
private void serialConnectClick(object sender, EventArgs e)
{
if (!_serialConnected)
{
_serialConnected = SerialConnect(portCombo.Text, int.Parse(baudCombo.Text));
if (!_serialConnected)
{
portCombo.SelectedIndex = 0;
messageTextBox.Text += "Failed to connect.\r\n";
return;
}
serialConnectBtn.Text = "Disconnect";
serialStatusLabel.Text = "Serial: Connected";
serialStatusLabel.ForeColor = Color.Blue;
messageTextBox.Text += "Connected\r\n";
VDIportCombo.Enabled = false;
soundSuccess.Play();
UpdateMessageBox(); // this is an async function
}
}
这会不断调用ReadLineAsync
并将结果添加到文本框中:
public async Task UpdateMessageBox()
{
messageTextBox.Text += "Reading data from serial.";
while (_serialConnected)
{
string message = await SerialReadLineAsync(serial);
messageTextBox.Text += message;
}
}
这就是ReadAsync
上的SerialPort.BaseStream
,只有当我们得到一个完整的行时才会返回数据(用换行符表示):
async Task<string> SerialReadLineAsync(SerialPort serialPort)
{
byte[] buffer = new byte[1];
string result = string.Empty;
Debug.WriteLine("Let's start reading.");
while (true)
{
await serialPort.BaseStream.ReadAsync(buffer, 0, 1);
result += serialPort.Encoding.GetString(buffer);
if (result.EndsWith(serialPort.NewLine))
{
result = result.Substring(0, result.Length - serialPort.NewLine.Length);
result.TrimEnd('\r','\n');
Debug.Write(string.Format("Data: {0}", result));
result += "\r\n";
return result;
}
}
}
我做的一切都正确吗?我可以从UI线程调用异步方法吗?视觉工作室告诉我应该使用等待,但它只是暗示。
我希望其他代码在连续读取时在UI线程上运行,所以我不想await
UpdateMessageBox
函数。如果这是一个线程,我只想让读取线程在后台运行,我只想做myReadThread.Start()
,是否有类似异步的东西?
编辑:只是为了澄清,这段代码确实有效,但我想知道这是否是“正确”的方式来做我正在做的事情。
你需要改变:
private void serialConnectClick(object sender, EventArgs e)
至
private async void serialConnectClick(object sender, EventArgs e)
...并将对UpdateMessageBox();
的调用更改为:
await UpdateMessageBox().ConfigureAwait(true);
UpdateMessageBox
应该使用ConfigureAwait(true)
来捕获当前上下文(UI),否则messageTextBox.Text += message;
将在不同的线程上执行:
public async Task UpdateMessageBox()
{
messageTextBox.Text += "Reading data from serial.";
while (_serialConnected)
{
string message = await SerialReadLineAsync(serial).ConfigureAwait(true);
messageTextBox.Text += message;
}
}
在SerialReadLineAsync
,你可以改变:
await serialPort.BaseStream.ReadAsync(buffer, 0, 1);
...至:
await serialPort.BaseStream.ReadAsync(buffer, 0, 1).ConfigureAwait(false);
...因为SerialReadLineAsync
语句与UI无关。
一般的提示是“一直异步”,这意味着await
s async
方法的任何方法也需要制作async
,反过来await
ed。重复调用堆栈。