一.线程的调用
1.无参
def run_01():
for i in range(6, 10):
print("test01", i)
time.sleep(1)
th_01 = threading.Thread(target=run_01) # 创建线程
th_01.start() # 启动线程
for i in range(0, 5):
print("main", i)
time.sleep(1)
threading中最主要的类就是Thread,我们可通过实例化Thread类来创建一个子线程,target参数为运行的事件。
start()方法为启动线程,线程运行结束或报异常时自动会结束线程。
程序默认在主线程上运行,不做任何操作的话,子线程和主线程是同步进行的。
2.有参
def run_01(a):
for i in range(6, 10):
print("test01", i)
time.sleep(1)
th_01 = threading.Thread(target=run_01, args=("test",)) # 创建线程
th_01.start() # 启动线程
若运行的事件有参数时,我们可通过args传入一个元组入参,也可通过kwargs传入字典类型。
def run_01(a):
for i in range(6, 10):
print("test01", i)
time.sleep(1)
th_01 = threading.Thread(target=run_01, kwargs={"a": "test"}) # 创建线程
th_01.start() # 启动线程
key值要与参数值保持一致。
3.多参
def run_01(a, b):
for i in range(6, 10):
print("test01", i)
time.sleep(1)
th_01 = threading.Thread(target=run_01, args=(1, 2)) # 创建线程
or
th_01 = threading.Thread(target=run_01, kwargs={"a": "test", "b": 1}) # 创建线程
th_01.start() # 启动线程
和单个入参差不多,多传入一个参数即可。
二.设置线程名称,获取线程状态
1.子线程名称默认是Thread-1,Thread-2…..,我们可通过Thread类中name属性设置线程名,
def run():
for i in range(0, 5):
print(i)
thread = threading.Thread(target=run, name='test') # name设置线程名
print(thread.name, thread.getName()) # name,getname()方法获取线程名
通过name属性和getName()方法获取线程名。修改/设备线程名也可通过setName()方法设置。
thread = threading.Thread(target=run, name='test') # name设置线程名
thread.setName("updateThreadName")
print(thread.name, thread.getName()) # name,getName()方法获取线程名
2.is_alive()为获取线程当前的运行状态
def run():
for i in range(0, 5):
print(i)
thread = threading.Thread(target=run, name='test') # name设置线程名
thread.start()
bol = thread.is_alive() # 为true时表示正在运行,为false时停止运行
print(bol)
三.主/子线程执行顺序
1.默认情况下主/子线程会同时执行,主线程会等待子线程结束后再结束。
def run():
for i in range(0, 5):
print("thread", i)
time.sleep(2)
if __name__ == '__main__':
thread = threading.Thread(target=run)
thread.start()
for i in range(5, 10):
print("main", i)
time.sleep(1)
2.Thread类中有个daemon属性可控制执行结果
if __name__ == '__main__':
thread = threading.Thread(target=run,daemon=True)
thread.start()
for i in range(5, 10):
print("main", i)
time.sleep(1)
创建子线程时我们将daemon设置为True,可以看出主线程结束后子线程也会结束运行,
不会等待子线程结束后再结束。也可通过setDaemon()方法设置。
if __name__ == '__main__':
thread = threading.Thread(target=run)
thread.setDaemon(True)
thread.start()
for i in range(5, 10):
print("main", i)
time.sleep(1)
四.join()用法
1.join()为堵塞主线程执行,优先执行子线程,等子线程执行完后再去执行主线程。
def run():
for i in range(0, 5):
print("thread1", i)
time.sleep(1)
def run2():
for i in range(0, 5):
print("thread2", i)
time.sleep(1)
if __name__ == '__main__':
thread = threading.Thread(target=run)
thread2 = threading.Thread(target=run2)
thread.start()
thread.join() # 开始堵塞主线程,只执行thread线程
thread2.start()
for i in range(5, 10):
print("main", i)
time.sleep(1)
2.join(timeout=None)中timeout参数
timeout默认为None,可传递秒数,设置堵塞主线程的时间,timeout秒后不管子线程有没有运行完都会执行主线程。
thread.join(timeout=2.0)
五.Event()方法的使用
我们都知道一个进程有多个线程,多个线程之间的资源是共享的,那么如果多个线程去修改同
一个资源数据,就会出现数据错乱的情况。Event类可以去堵塞线程的运行,我们先来看下Event()的几个方法。
1.实例化Event()类
event = threading.Event()
Event()中有个_flag的私有属性,默认为false,表示堵塞
2.wait()调用后表示开始堵塞
event.wait(timeout=2.0) # 调用该方法后,该线程会被堵塞,timeout为堵塞时间
3.set()方法设置flag为true,表示结束堵塞
event.set() # 设置self._flag = True
4.清除设置,flag值恢复false,继续堵塞
event.clear() # self._flag = False
5.is_set()查看flag的值
print(event.is_set()) # 查看当前_flag的值
6.实例
import threading
import time
def run(event):
print("当前flag的值", event.is_set())
event.wait() # 开始堵塞
for i in range(1, 6):
print(i)
time.sleep(1)
if event.is_set() == False:
break
event = threading.Event() # self._flag = False
thread = threading.Thread(target=run, args=(event,))
thread.start()
print("\n开始堵塞2s")
time.sleep(2)
event.set() # 设置self._flag = True
print("结束堵塞,运行2s")
time.sleep(2)
print("结束运行,跳出for循环")
event.clear() # self._flag = False
解析:
上述中,子线程执行到event.wait()时就开始进行堵塞,主线程等待2s后调用set()方法使子线程继续运行,
子线程循环两次后主线程调用clear()设置flag值为false,子线程if判断跳出循环,运行结束。
文章来源:https://www.cnblogs.com/lihongtaoya/ ,请勿转载
Original: https://www.cnblogs.com/lihongtaoya/p/16862244.html
Author: 余生没有余生
Title: 线程(Thread)基本用法
原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/798316/
转载文章受原作者版权保护。转载请注明原作者出处!