当前位置： 移动技术网 > IT编程>脚本编程>Python > python中threading开启关闭线程操作

python中threading开启关闭线程操作

2020年05月15日  | 移动技术网IT编程  | 我要评论

特福芬官网,super金融官网,发外链工具

在python中启动和关闭线程：

首先导入threading

import threading

然后定义一个方法

def serial_read():
...
...

然后定义线程，target指向要执行的方法

mythread = threading.thread(target=serial_read)

启动它

mythread.start()

二、停止线程

不多说了直接上代码

import inspect
import ctypes
def _async_raise(tid, exctype):
  """raises the exception, performs cleanup if needed"""
  tid = ctypes.c_long(tid)
  if not inspect.isclass(exctype):
    exctype = type(exctype)
  res = ctypes.pythonapi.pythreadstate_setasyncexc(tid, ctypes.py_object(exctype))
  if res == 0:
    raise valueerror("invalid thread id")
  elif res != 1:
    # """if it returns a number greater than one, you're in trouble,
    # and you should call it again with exc=null to revert the effect"""
    ctypes.pythonapi.pythreadstate_setasyncexc(tid, none)
    raise systemerror("pythreadstate_setasyncexc failed")
def stop_thread(thread):
  _async_raise(thread.ident, systemexit)

停止线程

stop_thread(mythread)

补充知识：python threading实现thread的修改值，开始，运行，停止，并获得内部值

下面的半模版代码在 win7+python3.63 运行通过并且实测可行，为了广大想要实现python的多线程停止的同学

import threading
import time
class mythread(threading.thread):
  def __init__(self):
    threading.thread.__init__(self)
    self.flag=true        #停止标志位
    self.parm=0         #用来被外部访问的
    #自行添加参数
  
  def run(self):
    while(true):
      if(not self.flag):
        break
      else:
        time.sleep(2)
  
  def setflag(self,parm):     #外部停止线程的操作函数
    self.flag=parm #boolean
 
  def setparm(self,parm):     #外部修改内部信息函数
    self.parm=parm
 
  def getparm(self):       #外部获得内部信息函数
    return self.parm
 
 
if __name__=="__main__":
  testthread=mythread()
  testthread.setdaemon(true)     #设为保护线程，主进程结束会关闭线程
  testthread.getparm()      #获得线程内部值
  testthread.setparm(1)      #修改线程内部值
  testthread.start()       #开始线程
  print(testthread.getparm())    #输出内部信息
  time.sleep(2)          #主进程休眠 2 秒
  testthread.setflag(false)      #修改线程运行状态
  time.sleep(2)          #2019.04.25 修改
  print(testthread.is_alive())  #查看线程运行状态

于2018-08-24修正一次，修正为在继承thread.thread时，没有对父类初始化

旧：

def __init__(self):
    self.flag=true        #停止标志位
    self.parm=0         #用来被外部访问的
    #自行添加参数

新：

def __init__(self):
    threading.thread.__init__(self)
    self.flag=true        #停止标志位
    self.parm=0         #用来被外部访问的
    #自行添加参数

于2019年4月25日进行第二次修正，发现设置flag值后仍为true输出的情况，原因是输出在修改完成前执行，睡眠后结果正常

以上这篇python中threading开启关闭线程操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持移动技术网。

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网