在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