　　python怎么终止进程,python多线程终止

　　Python终止线程的方法：1。调用stop函数，使用join函数等待线程正常退出；2.引发异常；在python线程中；3.以“thread.join”结束线程。

　　操作环境：windows7系统，python3.5版本3.5，戴尔G3电脑。

前言零

我们知道，在python中终止一个线程，传统的方式是设置/检查 ---标志或者锁.

　　这是一个好方法吗？

　　应该不好吧！因为所有的编程语言，突然地终止一个线程，这无论如何都不是一个好的设计模式.

　　同时

　　在某些情况下，甚至更糟，比如：

　　当一个线程打开一个必须合理关闭的关键资源时，比如打开一个可读可写的文件；该线程已经创建了其他几个线程，这些线程也需要被关闭(存在后代线程跑偏的风险！)。简单来说，我们的一大群线程共享公共资源，你希望其中一个“离开”。如果这个线程恰好在占用资源，强行让它离开的结果就是资源被锁起来，大家都拿不到！怎么样？有点像神仙小说的情节！

　　知道为啥threading仅有start而没有end不？

　　你看，线程一般用于网络连接，释放系统资源，转储流文件。这些都和IO有关。你突然关闭了线程。

　　如果没关好呢？你只是给自己制造bug吗？啊？

　　所以在这种事情中最重要的不是终止线程而是线程的清理.

　　00-1010比较nice的一种方法是每个线程携带一个退出请求标志，在线程中每隔一定时间检查一次，看看是不是自己该离开了！

　　导入线程

　　类StoppableThread(线程。螺纹):

　　“”带有stop()方法的线程类。线程本身必须检查

　　定期为stopped()条件。

　　def __init__(self):

　　超级(StoppableThread，self)。__init__()

　　自我。_stop_event=线程。事件()

　　定义停止(自我):

　　自我。_stop_event.set()

　　def停止(自身):

　　返回。_ stop _ event.is _ set()如这部分代码所示，当要退出线程时，应该调用stop()函数，并使用join()函数等待线程合适地退出.线程应该定期检测stop标志。

　　然而，有一些使用场景你真的需要杀死一个线程：例如，当你打包一个外部库，但是这个外部库是在长时间调用,所以你想中断这个进程。

　　【推荐：python视频教程】

　　00-1010下一个解决方案是允许在python线程中引发异常(当然有一些限制)。

　　def _async_raise(tid，exctype):

　　在id为tid的线程中引发异常

　　如果不是inspect.isclass(exctype):

　　引发TypeError(只能引发类型(不能引发实例))

　　RES=ctypes . python API . pythreadstate _ SetAsyncExc(tid，

　　ctypes.py_object(exctype))

　　如果res==0:

　　提升值错误(“无效线程id”)

　　埃利夫水库！=1:

　　# 如果它返回一个大于1的数字，您就有麻烦了，

　　#你应该

　　uld call it again with exc=NULL to revert the effect"

　　 ctypes.pythonapi.PyThreadState_SetAsyncExc(tid, 0)

　　 raise SystemError("PyThreadState_SetAsyncExc failed")

　　class ThreadWithExc(threading.Thread):

　　 '''A thread class that supports raising exception in the thread from

　　 another thread.

　　 '''

　　 def _get_my_tid(self):

　　 """determines this (self's) thread id

　　 CAREFUL : this function is executed in the context of the caller

　　 thread, to get the identity of the thread represented by this

　　 instance.

　　 """

　　 if not self.isAlive():

　　 raise threading.ThreadError("the thread is not active")

　　 # do we have it cached?

　　 if hasattr(self, "_thread_id"):

　　 return self._thread_id

　　 # no, look for it in the _active dict

　　 for tid, tobj in threading._active.items():

　　 if tobj is self:

　　 self._thread_id = tid

　　 return tid

　　 # TODO: in python 2.6, there's a simpler way to do : self.ident

　　 raise AssertionError("could not determine the thread's id")

　　 def raiseExc(self, exctype):

　　 """Raises the given exception type in the context of this thread.

　　 If the thread is busy in a system call (time.sleep(),

　　 socket.accept(), ...), the exception is simply ignored.

　　 If you are sure that your exception should terminate the thread,

　　 one way to ensure that it works is:

　　 t = ThreadWithExc( ... )

　　 ...

　　 t.raiseExc( SomeException )

　　 while t.isAlive():

　　 time.sleep( 0.1 )

　　 t.raiseExc( SomeException )

　　 If the exception is to be caught by the thread, you need a way to

　　 check that your thread has caught it.

　　 CAREFUL : this function is executed in the context of the

　　 caller thread, to raise an excpetion in the context of the

　　 thread represented by this instance.

　　 """

　　 _async_raise( self._get_my_tid(), exctype )正如注释里面描述，这不是啥“灵丹妙药”，因为，假如线程在python解释器之外busy，这样子的话终端异常就抓不到啦~

　　这个代码的合理使用方式是：让线程抓住一个特定的异常然后执行清理操作。这样的话你就能终端一个任务并能合适地进行清除。

解决方案 · 叁

假如我们要做个啥事情，类似于中断的方式，那么我们就可以用thread.join方式。

join的原理就是依次检验线程池中的线程是否结束，没有结束就阻塞直到线程结束，如果结束则跳转执行下一个线程的join函数。

　　先看看这个：

　　1. 阻塞主进程，专注于执行多线程中的程序。

　　2. 多线程多join的情况下，依次执行各线程的join方法，前头一个结束了才能执行后面一个。

　　3. 无参数，则等待到该线程结束，才开始执行下一个线程的join。

　　4. 参数timeout为线程的阻塞时间，如 timeout=2 就是罩着这个线程2s 以后，就不管他了，继续执行下面的代码。

# coding: utf-8
　　# 多线程join
　　import threading, time 
　　def doWaiting1(): 
　　 print 'start waiting1: ' + time.strftime('%H:%M:%S') + "\n" 
　　 time.sleep(3) 
　　 print 'stop waiting1: ' + time.strftime('%H:%M:%S') + "\n" 
　　def doWaiting2(): 
　　 print 'start waiting2: ' + time.strftime('%H:%M:%S') + "\n" 
　　 time.sleep(8) 
　　 print 'stop waiting2: ', time.strftime('%H:%M:%S') + "\n" 
　　tsk = [] 
　　thread1 = threading.Thread(target = doWaiting1) 
　　thread1.start() 
　　tsk.append(thread1)
　　thread2 = threading.Thread(target = doWaiting2) 
　　thread2.start() 
　　tsk.append(thread2)
　　print 'start join: ' + time.strftime('%H:%M:%S') + "\n" 
　　for tt in tsk:
　　 tt.join()
　　print 'end join: ' + time.strftime('%H:%M:%S') + "\n"

默认join方式，也就是不带参，阻塞模式，只有子线程运行完才运行其他的。

　　1、两个线程在同一时间开启，join 函数执行。

　　2、waiting1 线程执行（等待）了3s 以后，结束。

　　3、waiting2 线程执行（等待）了8s 以后，运行结束。

　　4、join 函数（返回到了主进程）执行结束。

这里是默认的join方式，是在线程已经开始跑了之后，然后再join的，注意这点，join之后主线程就必须等子线程结束才会返回主线。
　　

join的参数，也就是timeout参数，改为2，即join（2），那么结果就是如下了：

两个线程在同一时间开启，join 函数执行。
　　
wating1 线程在执行（等待）了三秒以后，完成。
　　
join 退出（两个2s，一共4s，36-32=4，无误）。
　　
waiting2 线程由于没有在 join 规定的等待时间内（4s）完成，所以自己在后面执行完成。

join(2)就是:我给你子线程两秒钟，每个的2s钟结束之后我就走，我不会有丝毫的顾虑！
　　

以上就是python如何终止线程的详细内容，更多请关注盛行IT软件开发工作室其它相关文章！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

前言 零

解决方案 · 叁

相关文章阅读

前言零