0

我正在运行两个 python 线程（import threading）。他们俩都在open()通话中被阻止；事实上，他们试图打开命名管道以写入它们，因此在有人尝试从命名管道读取之前阻塞是一种正常的行为。

简而言之，它看起来像：

import threading

def f():
    open('pipe2', 'r')

if __name__ == '__main__':
    t = threading.Thread(target=f)
    t.start()
    open('pipe1', 'r')

当我键入 ^C 时，open()主线程中的 被中断（引发IOErrorerrno == 4）。

我的问题是：t线程仍在等待，我想传播中断行为，以使其也提高IOError。

4

1 回答 1

0

我在 python 文档中找到了这一点：
“ ...只有主线程可以设置新的信号处理程序，并且主线程将是唯一接收信号的线程（这是由 Python 信号模块强制执行的，即使底层线程实现支持向单个线程发送信号）。这意味着信号不能用作线程间通信的手段。请改用锁。“
也许您还应该查看这些文档：
exceptions.KeyboardInterrupt

库/signal.html

另一种想法是使用 select 在线程中异步读取管道。这适用于 Linux，不确定 Windows（它不是​​最干净的，也不是最好的实现）：

   #!/usr/bin/python

   import threading
   import os
   import select

   def f():
           f = os.fdopen(os.open('pipe2', os.O_RDONLY|os.O_NONBLOCK))
           finput = [ f ]
           foutput = []
           # here the pipe is scanned and whatever gets in will be printed out
           # ...as long as 'getout' is False
           while finput and not getout:
                   fread, fwrite, fexcep = select.select(finput, foutput, finput)
                   for q in fread:
                           if q in finput:
                                   s = q.read()
                                   if len(s) > 0:
                                           print s

   if __name__ == '__main__':
           getout = False
           t = threading.Thread(target=f)
           t.start()
           try:
                   open('pipe1', 'r')
           except:
                   getout = True
于 2012-04-11T09:03:31.253 回答