2

我编写了一个程序,它读取一个文本文件并为文本文件中的每一行运行一个 .exe。这导致每次运行 .exe 时都会打开一个新的命令行窗口。当前任务完成后,窗口会自行关闭,但问题如下:

如果我在文本文件中有 100 行,这意味着我调用 .exe 文件 100 次。我的问题是如果我想在它已经开始后取消运行,我必须点击红色的“X”来一个接一个地关闭每个窗口。

我想做的是让某种命令中断正在运行的程序,或者关闭所有即将到来的窗口,或者只是停止 for 循环的运行。

是否可以在控制台中写入命令来中断当前正在运行的代码?

使用某种关键事件监听器会更好吗?如果是这样,Python 中是否有任何内置的关键侦听器?我似乎找不到任何东西。这是否意味着我必须安装 Pygame 才能使用关键事件侦听器?

也许我应该尝试听命令行并在我手动关闭的一个窗口上检测退出代码,然后结束 for 循环?

4

1 回答 1

3

有几种方法可以解决这个问题。但是几乎你有一个主要问题 - 你需要某种可以切换的标志,以便代码知道它必须停止。例如,如果代码在一个while循环中工作,它应该在这个循环的开始检查标志是否有效,或者标志是否告诉循环停止......

while flag:
    # do code

有几种方法可以根据您的需要实现这种类似标记的操作。我将讨论线程选项。首先,您需要了解线程是如何工作的,然后您需要塑造您的脚本,以便不是为文本文件的每一行“运行可执行文件”,而是读取文本文件,并将所有行放入队列中,那么您将有几个线程从该队列中读取,并执行所需的操作(例如运行可执行文件),但您应该使用 Python 来模仿这个,而不是运行外部可执行文件,这个线程应该是一个守护线程......并且它应该有一个主循环,用于检查父线程中存在的标志是否打开......

下面是一个例子:

from threading import Thread
from Queue import Queue
import sys
import time

class Performer():
    def __init__(self):
        self.active = False
        self.queue = Queue()

    def action(self, line):
        pass # your code should be here

    def operate(self, text_file, threads=5):
        with open(text_file) as f:
            for line in f:
                self.queue.put(line)

        self.active = True
        thread_pool = []
        for i in range(threads):
            t = Thread(target=self.__thread, name=('worker-%d' % i))
            t.daemon = True
            t.start()
            thread_pool.append(t)

        while self.active:
            try:
                if self.queue.empty():
                    break
            except KeyboardInterrupt:
                self.active = False
                sys.exit('user + keyboard = byebye')
            else:
                time.sleep(1)

    def __thread(self):
        while self.active:
            if not self.queue.empty():
                try:
                    self.action(self.queue.get())
                except Exception:
                    pass # do something here
于 2013-06-27T12:01:34.673 回答