如何停止Python中的后台线程

2024-06-02 11:42:23 发布

您现在位置:Python中文网/ 问答频道 /正文

以下是用于说明的代码片段。C1.infinite_loop()方法正在作为后台线程运行。我想确保如果有人按下Ctrl+C,然后优雅地终止程序。我需要重写什么方法以及在哪里处理Ctrl+C信号?我想在生成Ctrl+C时设置一个标志,并在C1.infinite_循环中定期检查。如果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在写。在这种情况下我还需要使用锁吗?在


Tags: 方法importselflooptimeinitdeflist
1条回答
网友
1楼 · 发布于 2024-06-02 11:42:23

并使用无限标志终止循环

#!/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()

相关问题 更多 >