在异步调用c#中包装一个同步函数

Question

我有一个服务器，它必须通过网络轮询一个设备，以获取信息，处理它，然后将它发送给用户。 设备勘测成为同步阻塞功能。

我的问题是：

如何创建一个自己的异步函数版本来使用Task或其他异步模式来执行这个函数？？？

考虑以下代码从设备获取信息：

IEnumerable<Logs> GetDataFromEquipment(string ipAddress)
        {
            Equipment equipment = new Equipment();
            //Open communication with equipment. Blocking code.
            int handler = equipment.OpenCommunication(ipAddress);
            //get data from equipment. Blocking code.
            IEnumerable<Logs> logs = equipment.GetLogs(handler);
            //close communication with equipment
            equipment.CloseCommunication(handler);

            return logs;
        }

谢谢

Answer 1

你可以使用异步/等待

 public async Task<IEnumerable<Logs>> GetDataFromEquipment(string ipAddress)
    {

        var task = Task.Run(() =>
        {
            Equipment equipment = new Equipment();
            //Open communication with equipment. Blocking code.
            int handler = equipment.OpenCommunication(ipAddress);
            //get data from equipment. Blocking code.
            IEnumerable<Logs> logs = equipment.GetLogs(handler);
            //close communication with equipment
            equipment.CloseCommunication(handler);

            return logs;
        });

        return await task;
    }