为什么我的异步方法不等待“serialPort = await SerialDevice.FromIdAsync()”?

问题描述 投票:1回答:2

我正在尝试创建一个初始化树莓和arduino之间串行连接的类。该类还应该能够通过已建立的串行连接进行读写。

我使用的代码来自microsoft developers website

using Windows.Storage.Streams;
using Windows.Devices.Enumeration;
using Windows.Devices.SerialCommunication;

public async void Serial()
{
    /* Find the selector string for the serial device   */
    string aqs = SerialDevice.GetDeviceSelector("UART0");
    /* Find the serial device with our selector string  */
    var dis = await DeviceInformation.FindAllAsync(aqs);
    /* Create an serial device with our selected device */
    SerialDevice SerialPort = await SerialDevice.FromIdAsync(dis[0].Id);
    /* Configure serial settings */
    SerialPort.WriteTimeout = TimeSpan.FromMilliseconds(1000);
    SerialPort.ReadTimeout = TimeSpan.FromMilliseconds(1000);
    SerialPort.BaudRate = 9600;
    SerialPort.Parity = SerialParity.None;
    SerialPort.StopBits = SerialStopBitCount.One;
    SerialPort.DataBits = 8;

    /* Write a string out over serial */
    string txBuffer = "Hello Serial";
    DataWriter dataWriter = new DataWriter();
    dataWriter.WriteString(txBuffer);
    uint bytesWritten = await SerialPort.OutputStream.WriteAsync(dataWriter.DetachBuffer());

    /* Read data in from the serial port */
    const uint maxReadLength = 1024;
    DataReader dataReader = new DataReader(SerialPort.InputStream);
    uint bytesToRead = await dataReader.LoadAsync(maxReadLength);
    string rxBuffer = dataReader.ReadString(bytesToRead);
}

我将serialcommunication功能添加到Package.appxmanifest。

<Capabilities>
  <DeviceCapability Name="serialcommunication">
    <Device Id="any">
      <Function Type="name:serialPort" />
    </Device>
  </DeviceCapability>
</Capabilities>

到目前为止一切正常。 Raspberry在另一端成功地发送和接收来自Arduino的消息。

现在我尝试单独执行这些步骤。首先初始化串行连接,因此只要应用程序需要,就可以使用读写函数。

主页

namespace SerialUART
{
    public sealed partial class MainPage : Page
    {
        private SerialController serial = new SerialController();

        public MainPage()
        {
            this.InitializeComponent();
            serial.Write();
            serial.Read();
        }
    }
}

SerialController

using Windows.Devices.Enumeration;
using Windows.Devices.SerialCommunication;
using Windows.Storage.Streams;

namespace SerialUART
{
    class SerialController
    {
        private SerialDevice SerialPort;
        private DataWriter dataWriter;
        private DataReader dataReader;

        public SerialController()
        {
            InitSerial();
        }

        private async void InitSerial()
        {
            string aqs = SerialDevice.GetDeviceSelector("UART0");
            var dis = await DeviceInformation.FindAllAsync(aqs);
            SerialPort = await SerialDevice.FromIdAsync(dis[0].Id);    
            // The program does not wait here and executes Write()
            // after Write() the following code will be executed
            SerialPort.WriteTimeout = TimeSpan.FromMilliseconds(1000);
            SerialPort.ReadTimeout = TimeSpan.FromMilliseconds(1000);
            SerialPort.BaudRate = 9600;
            SerialPort.Parity = SerialParity.None;
            SerialPort.StopBits = SerialStopBitCount.One;
            SerialPort.DataBits = 8;
            dataWriter = new DataWriter();
            dataReader = new DataReader(SerialPort.InputStream);
        }

        public async void Read()
        {
            /* Read data in from the serial port */
            const uint maxReadLength = 1024;
            uint bytesToRead = await dataReader.LoadAsync(maxReadLength);
            string rxBuffer = dataReader.ReadString(bytesToRead);
            Debug.WriteLine(rxBuffer);
        }

        public async void Write()
        {
            /* Write a string out over serial */
            string txBuffer = "Hello Serial";
            dataWriter.WriteString(txBuffer);
            uint bytesWritten = await SerialPort.OutputStream.WriteAsync(dataWriter.DetachBuffer());
       }
    }
}

此代码不会等待serialPort,dataWriter和dataReader初始化。所以他们永远不会被分配到。

任何人都可以向我解释为什么它不等待串行连接?它应该如何完成?

c# asynchronous raspberry-pi3 windows-10-iot-core
2个回答
11
投票

你所有的async方法返回void - 这意味着它们开始执行,并且调用代码没有简单的方法等待,直到它实际完成后再继续。一旦你在尚未完成的事情上使用await表达式,异步方法将返回到调用者,已经安排了一个延续,它将在awaitable完成时执行。在你的情况下,你只是继续下一个声明。

相反,您应该让异步方法返回Task,并在继续之前更改您的调用方法以等待异步方法完成。这很难做得很优雅,因为在每种情况下你都是从构造函数调用异步方法,它们本身不能是异步的。您可能需要考虑使用异步静态方法而不是在构造函数中执行工作,构造函数可以调用异步方法,等待它们,然后调用不执行任何实际工作的实际构造函数。

在你进入任何一个详细的变化之前,你应该真正阅读更多关于asyncawait做什么 - 尝试使用它们而不理解它们是进一步问题的一个秘诀。


1
投票

这是你的构造函数:

public SerialController()
{
    InitSerial();
}

它调用InitSerial()方法,其中有几个等待它们。构造函数立即返回,而不执行所需的所有操作。然后你调用这些方法:

serial.Write();
serial.Read();

但是这些方法依赖于在InitSerial方法中执行的每一行代码,但显然它们没有。

解决这个问题的一种方法是让InitSerial不是私人的(内部或公共的)并让它返回Task。当你调用它时,你需要等待它,以便它已被执行完毕。之后,你可以打电话给serial.Write()Serial.Read()

你应该避免使用async void。它们仅用于事件处理。对于其他方法返回TaskTask<T>

© www.soinside.com 2019 - 2024. All rights reserved.