这个问题 – 如何从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