线程(Thread)基本用法

2022 年 11 月 19 日
筆記
Python

一.线程的调用

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判断跳出循环，运行结束。

文章来源：//www.cnblogs.com/lihongtaoya/ ，请勿转载

Tags: Python