在扭曲的程序中中断 raw_input答案

【问题标题】：Interrupt raw_input in a twisted program在扭曲的程序中中断 raw_input
【发布时间】：2013-12-02 18:56:47
【问题描述】：

所以我正在做的是：

def interrupted(signum, stackframe):
    log.warning('interrupted > Got signal: %s', signum)
    menu.quitMenu = True # to stop my code

signal.signal(signal.SIGINT, interrupted) # Handle KeyboardInterrupt

问题是，虽然菜单被通知它必须停止，并且很快就会停止，但它现在不能这样做，因为它被困在raw_input：

def askUser(self):
    current_date   = datetime.now().isoformat(' ')
    choice = raw_input('%s > ' % current_date)
    return choice

因此，由于 twisted 正在删除默认中断处理程序，raw_input 不会停止。我仍然需要在^C 之后按enter 才能停止。

如何在不安装默认中断处理程序的情况下强制停止 raw_input，这是扭曲上下文中问题的根源（因为扭曲本身不会被中断） p>

我猜这个问题与raw_input 无关：任何需要无限时间（或超过预设限制）的函数都应该以某种方式中断。

这有一个公认的扭曲模式吗？

编辑

这是完整的测试代码：

from datetime import datetime

class Menu:

    def __init__(self):
        self.quitMenu = False

    def showMenu(self):
        print '''

A) Do A
B) Do B

'''

    def askUser(self):
        current_date   = datetime.now().isoformat(' ')
        choice = raw_input('%s > Please select option > ' % current_date)
        print
        return choice

    def stopMe(self):
        self.quitMenu = True

    def alive(self):
        return self.quitMenu == False

    def doMenuOnce(self):
        self.showMenu()
        choice = self.askUser()
        if not self.alive() : # Maybe somebody has tried to stop the menu while in askUser
            return
        if   choice == 'A' : print 'A selected'
        elif choice == 'B' : print 'B selected'
        else               : print 'ERR: choice %s not supported' % (choice)

    def forever(self):
        while self.alive():
            self.doMenuOnce()

from twisted.internet import reactor, threads
import signal

class MenuTwisted:

    def __init__(self, menu):
        self.menu = menu
        signal.signal(signal.SIGINT, self.interrupted) # Handle KeyboardInterrupt

    def interrupted(self, signum, stackframe):
        print 'Interrupted!'
        self.menu.stopMe()

    def doMenuOnce(self):
        threads.deferToThread(self.menu.doMenuOnce).addCallback(self.forever)

    def forever(self, res=None):
        if self.menu.alive() :
            reactor.callLater(0, self.doMenuOnce)
        else : 
            reactor.callFromThread(reactor.stop)

    def run(self):
        self.forever()
        reactor.run()

我可以以两种不同的方式运行。

正常方式：

menu = Menu()
menu.forever()

按下^C 立即停止程序：

A) Do A
B) Do B


2013-12-03 11:00:26.288846 > Please select option > ^CTraceback (most recent call last):
  File "twisted_keyboard_interrupt.py", line 72, in <module>
    menu.forever()
  File "twisted_keyboard_interrupt.py", line 43, in forever
    self.doMenuOnce()
  File "twisted_keyboard_interrupt.py", line 34, in doMenuOnce
    choice = self.askUser()
  File "twisted_keyboard_interrupt.py", line 22, in askUser
    choice = raw_input('%s > Please select option > ' % current_date)
KeyboardInterrupt

正如预期的那样。

扭曲的方式：

menu = Menu()
menutw = MenuTwisted(menu)
menutw.run()

按^C 将产生：

A) Do A
B) Do B


2013-12-03 11:04:18.678219 > Please select option > ^CInterrupted!

但是askUser实际上并没有被打断：我还需要按enterraw_input才能完成。

【问题讨论】：

标签： python twisted interrupt keyboard-events keyboardinterrupt

【解决方案1】：

处理这个问题的正确方法是handle console input asynchronously，而不是试图使阻塞输入函数可中断。换句话说，raw_input 从根本上是解决您所攻击问题的错误解决方案。

但是，如果你真的只是想了解这里发生了什么，诀窍是在调用reactor.callFromThread(reactor.stop) 之后，你必须以某种方式提示raw_input 退出；它不会正常进行。但是，由于您是在线程中运行它，它实际上根本不是可中断的，因为 Python 中的 only the main thread is interruptable。所以我认为你想要的实际上可能是不可能的。我相信关闭sys.stdin 可能会从raw_input 下拉出地毯，即使它在一个线程中，但似乎底层库正在做一些比简单地从FD 读取更聪明的事情，所以关闭它不会不错。

【讨论】：