在Windows上的os.pipe上无阻塞读取

这个问题 - 如何从os.pipe()读取而不被阻塞? - 显示了一个解决方案,如何检查os.pipe是否有Linux的任何数据,为此,您需要将管道置于非阻塞模式:

import os, fcntl
fcntl.fcntl(thePipe, fcntl.F_SETFL, os.O_NONBLOCK)

在Windows上,我们有这样的:

ImportError: No module named fcntl

os.pipe在那里:

>>> os.pipe()
(3, 4)

那么,是否有可能在Windows上执行非阻塞式读取或os.pipe的内容?


在通过StackOverflow挖掘一段时间后回答我自己的问题。

更新 :感谢@HarryJohnston改变了事情。

起初答案是否定的 ,在Windows上的os.pipe上无法进行非阻塞式读取。 从这个答案我明白了:

Windows中非阻塞/异步I / O的术语是“重叠的” - 这就是你应该看的。

Windows上的os.pipe是通过CreatePipe API实现的(请参阅这里以及...以及我在Python源代码中找不到os.pipe代码)。 CreatePipe制作匿名管道,而匿名管道不支持异步I / O。

但是 @HarryJohnston评论说SetNamedPipeHandleState doc允许匿名管道进入非阻塞模式。 我写了测试,并且因OSError: [Errno 22] Invalid argument失败OSError: [Errno 22] Invalid argument 。 错误消息似乎是错误的,所以我试图检查数据不可用时无阻塞读取操作应该返回什么结果,并且在读取有关命名管道模式的MSDN注释之后,我发现它应该是ERROR_NO_DATA ,它的int值为232 。添加ctypes.WinError()调用异常处理程序显示预期的[Error 232] The pipe is being closed.

所以,答案是肯定的 ,可以在Windows上的os.pipe上进行非阻塞式读取,这里是证明:

import msvcrt
import os

from ctypes import windll, byref, wintypes, GetLastError, WinError
from ctypes.wintypes import HANDLE, DWORD, POINTER, BOOL

LPDWORD = POINTER(DWORD)

PIPE_NOWAIT = wintypes.DWORD(0x00000001)

ERROR_NO_DATA = 232

def pipe_no_wait(pipefd):
  """ pipefd is a integer as returned by os.pipe """

  SetNamedPipeHandleState = windll.kernel32.SetNamedPipeHandleState
  SetNamedPipeHandleState.argtypes = [HANDLE, LPDWORD, LPDWORD, LPDWORD]
  SetNamedPipeHandleState.restype = BOOL

  h = msvcrt.get_osfhandle(pipefd)

  res = windll.kernel32.SetNamedPipeHandleState(h, byref(PIPE_NOWAIT), None, None)
  if res == 0:
      print(WinError())
      return False
  return True


if __name__  == '__main__':
  # CreatePipe
  r, w = os.pipe()

  pipe_no_wait(r)

  print os.write(w, 'xxx')
  print os.read(r, 1024)
  try:
    print os.write(w, 'yyy')
    print os.read(r, 1024)
    print os.read(r, 1024)
  except OSError as e:
    print dir(e), e.errno, GetLastError()
    print(WinError())
    if GetLastError() != ERROR_NO_DATA:
        raise
链接地址: http://www.djcxy.com/p/52497.html

上一篇: Non blocking read on os.pipe on Windows

下一篇: Tornado Web and Threads