解决python父线程关闭后子线程不关闭问题-kb88凯时官网登录

时间:2020-04-25
阅读:
免费资源网 - https://freexyz.cn/

我们都知道,python可以通过threading module来创建新的线程,然而在创建线程的线程(父线程)关闭之后,相应的子线程可能却没有关闭,这可能是因为代码中没有使用setdaemon(true)函数。

接下来,使用一个例子来说明:

import threading
def prt_hello() :
  while 1 :
    print 'hello'
if __name__ == '__main__' :
  t = threading.thread(target=prt_hello)
  t.setdaemon(true)
  t.start()

我们需要把setdaemon函数放在start函数前面,不然它是不给通过的,并且返回'cannot set daemon status of active thread‘

补充知识:python 多线程的退出/停止的一种是实现思路

在使用多线程的过程中,我们知道,python的线程是没有stop/terminate方法的,也就是说它被启动后,你无法再主动去退出它,除非主进程退出了,注意,是主进程,不是线程的父进程.

一个比较合理的方式就是把原因需要放到threading.thread的target中的线程函数,改写到一个继承类中,下面是一个实现例子

import threading
import time
import os
 
# 原本需要用来启动的无线循环的函数
def print_thread():
  pid = os.getpid()
  counts = 0
  while true:
    print(f'threading pid: {pid} ran: {counts:04d} s')
    counts  = 1
    time.sleep(1)
 
# 把函数放到改写到类的run方法中,便可以通过调用类方法,实现线程的终止
class stoppablethread(threading.thread):
 
  def __init__(self, daemon=none):
    super(stoppablethread, self).__init__(daemon=daemon)
    self.__is_running = true
    self.daemon = daemon
 
  def terminate(self):
    self.__is_running = false
 
  def run(self):
    pid = os.getpid()
    counts = 0
    while self.__is_running:
      print(f'threading running: {pid} ran: {counts:04d} s')
      counts  = 1
      time.sleep(1)
 
 
def call_thread():
  thread = stoppablethread()
  thread.daemon = true
  thread.start()
 
  pid = os.getpid()
  counts = 0
  for i in range(5):
    print(f'0 call threading pid: {pid} ran: {counts:04d} s')
    counts  = 2
    time.sleep(2)
  # 主动把线程退出
  thread.terminate()
 
 
if __name__ == '__main__':
  call_thread()
  print(f'==========call_thread finish===========')
  counts = 0
  for i in range(5):
    counts  = 1
    time.sleep(1)
    print(f'main thread:{counts:04d} s')
免费资源网 - https://freexyz.cn/
返回顶部
顶部
网站地图