python threading 结束线程

python threading 启动的线程,并没有提供终止线程的方法,现总结一下在网上找到的方法

1、通过threading.Thread._Thread__stop()结束线程

import time
import threading
def f():
    while 1:
        time.sleep(0.1)
        print(1)
 
 
t = threading.Thread(target=f)
t.start()
time.sleep(0.5)
print("Stopping the thread")
threading.Thread._Thread__stop(t)
print("Stopped the thread")


# 运行结果python2
1
1
1
1
Stopping the thread
Stopped the thread

# 运行结果 python3

1
1
1
1
Traceback (most recent call last):
  File "C:/work/1/reco/12月/tmp.py", line 64, in <module>
    threading.Thread._Thread__stop(t)
AttributeError: type object 'Thread' has no attribute '_Thread__stop'
Stopping the thread

Windows实验结果:python2时,p.isAlive()会报False,但实际进程并未结束。用python3会报错。

2、使用ctypes强行杀掉线程

import threading
import time
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)
 
 
def print_time(e):
    while 2:
        print(e)
 

if __name__ == "__main__":
    t = threading.Thread(target=print_time,args=("2"))
    t.start()
    time.sleep(0.001)
    stop_thread(t)
    print("stoped")
    time.sleep(2)
    t1 = threading.Thread(target=print_time,args=("1"))
    t1.start()
    time.sleep(0.001)
    stop_thread(t1)
    print("stoped")
    while 1:
        pass

windows实测:python2 可以结束进程,python3未测。


版权声明:本文为fenglepeng原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。