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

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

 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 。 错误消息似乎是错误的,所以我试图检查什么应该是返回结果的非阻塞读取操作时,数据不可用,并在读取命名管道模式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