有几种方法可以解决这个问题。但是几乎你有一个主要问题 - 你需要某种可以切换的标志,以便代码知道它必须停止。例如,如果代码在一个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