重叠 I/O 操作期间的串行端口和处理错误

Question

我最近一直在进行串行通信，因此我准备了一个类，作为所有负责读取、写入等的 Windows API 函数的简单接口。此类中的所有 I/O 操作都是异步处理的。

在回答我的问题之前，让我向您展示一下如何从串口写入和读取数据（这只是读取功能，因为写入的结构完全相同，所以没有必要同时介绍它们） 。

function TSerialPort.Read(var pBuffer; const lBufferSize: Cardinal): Cardinal;
var
  lOverlapped: OVERLAPPED;
  lLastError: Cardinal;
  lEvent: TEvent;
begin
  lEvent := TEvent.Create(nil, True, False, '');
  try
    FillChar(lOverlapped, SizeOf(lOverlapped), 0);
    lOverlapped.hEvent := lEvent.Handle;

    if not ReadFile(FSerialPortHandle, pBuffer, lBufferSize, Result, @lOverlapped) then
    begin
      lLastError := GetLastError;
      if (lLastError <> ERROR_IO_PENDING) and (lLastError <> ERROR_SUCCESS) then
        raise Exception.Create(SysErrorMessage(lLastError));

      case lEvent.WaitFor(INFINITE) of
        wrSignaled:
          if not GetOverlappedResult(FSerialPortHandle, lOverlapped, Result, False) then
            raise Exception.Create(SysErrorMessage(GetLastError));

        wrError:
          begin
            lLastError := lEvent.LastError;
            //this is a call to Windows.CancelIo(FSerialPortHandle);
            if Self.CancelIO() then
              lEvent.WaitFor(INFINITE);
            raise Exception.Create(SysErrorMessage(lLastError));
          end;
      end;
    end;
  finally
    FreeAndNil(lEvent);
  end;
end;

在你问我为什么在这个函数等待读取操作完成时打开串行端口进行重叠操作之前，这是我的解释 - 只有当以这种方式打开串行端口时，我才能指定 WaitCommEvent() 方法等待事件的时间。如果我打开非重叠操作的端口，WaitCommEvent() 将阻塞，直到串行端口上出现事件，而该事件并不总是发生，导致调用线程永远阻塞。

尽管如此，让我们集中讨论上面的 Read() 函数。

1）首先，我没有任何时间限制地等待事件被设置。当前线程是否有可能因某种原因永远阻塞？我不知道我是否可以 100% 确定该事件迟早会由异步执行读取操作的线程设置。我知道，当串行端口的读取超时全部设置为零时，读取操作将在读取给定的字节数之前完成，但这是我知道的行为。我的问题涉及意外情况，这些情况会导致事件永远不会被设置并且 WaitFor() 方法永远等待 - 它有可能发生吗？

2）WaitFor()可能会返回wrError，它通知在等待操作期间发生了一些错误（但这与重叠读取操作根本没有关系，对吧？）。因此我认为我不应该再等待读取操作完成，因为事件句柄可能不再可用，对吧？ 因此，我调用 CancelIO() 方法来取消读取操作，等待异步执行取消读取的线程设置事件，然后才引发异常。我等待该线程取消读取，因为如果我立即离开 Read() 方法（不取消 I/O），我会导致该线程将其数据（重叠的记录数据）写入局部变量，这将导致那么就不再有效了，对吗？ 另一方面，是否存在由于在引发异常之前调用 WaitFor(INFINITE) 而导致当前线程永远被阻塞的危险？

如果您告诉我上述陈述是否属实并发表评论，我将不胜感激。

预先非常感谢您。

Answer 1

只是出于好奇：为什么不使用现有的串行组件？

我使用 TurboPower Async 来接收 GPS 消息，但还有很多其他免费可用的：http://www.efg2.com/Lab/Library/Delphi/IO/PortIO .htm

其中大多数允许您在更高级别进行串行通信，为您抽象出所有较低级别的 IO 和线程内容。

这样，您只需编写一个 onreceive 处理程序来接收，并调用 send() 来发送内容。