如何在 Python 中停止后台线程
How to stop background thread in Python
这里是用于说明目的的代码片段。 C1.infinite_loop() 方法是 运行 作为后台线程。我想确定是否有人按 Ctrl+C 然后优雅地终止程序。我需要覆盖什么方法以及在哪里处理 Ctrl+C 信号?我想在生成 Ctrl+C 时设置一个标志,并定期检查内部 C1.infinite_loop。如果 flag 为真则跳出循环?这是正确的方法还是您有其他建议?
import time
import random
from threading import Thread
class C1:
def __init__(self):
self.list = list()
def infinite_loop(self):
while True:
self.list.append(random.randint(1,10))
time.sleep(2)
class C2:
def __init__(self):
print('inside C2 init')
self.c1 = C1()
def main(self):
self.bg_th = Thread(target=self.c1.infinite_loop)
self.bg_th.start()
def disp(self):
print(self.c1.list)
c2 = C2()
c2.main()
time.sleep(2)
c2.disp()
c2.bg_th.join()
还有一个问题。列表在此处的两个线程之间共享。 C2 正在读取,C1 正在写入。在这种情况下我还需要使用锁吗?
这使用标志和信号来终止无限循环
#!/usr/bin/env python
import signal
import sys
import time
import random
from threading import Thread
class C1:
def __init__(self):
signal.signal(signal.SIGINT,self.signal_handler)
self.keepgoing = True
self.list = list()
def infinite_loop(self):
while self.keepgoing:
self.list.append(random.randint(1,10))
time.sleep(2)
def signal_handler(self, sig, frame):
print('You pressed Ctrl+C!')
self.keepgoing = False
class C2:
def __init__(self):
print('inside C2 init')
self.c1 = C1()
def main(self):
self.bg_th = Thread(target=self.c1.infinite_loop)
self.bg_th.start()
def disp(self):
print(self.c1.list)
c2 = C2()
c2.main()
time.sleep(2)
c2.disp()
c2.bg_th.join()
这里是用于说明目的的代码片段。 C1.infinite_loop() 方法是 运行 作为后台线程。我想确定是否有人按 Ctrl+C 然后优雅地终止程序。我需要覆盖什么方法以及在哪里处理 Ctrl+C 信号?我想在生成 Ctrl+C 时设置一个标志,并定期检查内部 C1.infinite_loop。如果 flag 为真则跳出循环?这是正确的方法还是您有其他建议?
import time
import random
from threading import Thread
class C1:
def __init__(self):
self.list = list()
def infinite_loop(self):
while True:
self.list.append(random.randint(1,10))
time.sleep(2)
class C2:
def __init__(self):
print('inside C2 init')
self.c1 = C1()
def main(self):
self.bg_th = Thread(target=self.c1.infinite_loop)
self.bg_th.start()
def disp(self):
print(self.c1.list)
c2 = C2()
c2.main()
time.sleep(2)
c2.disp()
c2.bg_th.join()
还有一个问题。列表在此处的两个线程之间共享。 C2 正在读取,C1 正在写入。在这种情况下我还需要使用锁吗?
这使用标志和信号来终止无限循环
#!/usr/bin/env python
import signal
import sys
import time
import random
from threading import Thread
class C1:
def __init__(self):
signal.signal(signal.SIGINT,self.signal_handler)
self.keepgoing = True
self.list = list()
def infinite_loop(self):
while self.keepgoing:
self.list.append(random.randint(1,10))
time.sleep(2)
def signal_handler(self, sig, frame):
print('You pressed Ctrl+C!')
self.keepgoing = False
class C2:
def __init__(self):
print('inside C2 init')
self.c1 = C1()
def main(self):
self.bg_th = Thread(target=self.c1.infinite_loop)
self.bg_th.start()
def disp(self):
print(self.c1.list)
c2 = C2()
c2.main()
time.sleep(2)
c2.disp()
c2.bg_th.join()