当前位置：首页 > news >正文

python中多线程：线程插队方法join详解、线程停止、通过变量来让线程停止

news 2025/6/30 17:12:58

线程插队方法join详解

import threading
import time# 下载任务
def thread_body(movie_name):t = threading.current_thread()# 模拟耗时操作for i in range(5):print(f'{t.name} 线程正在下载{movie_name}中')time.sleep(1)# 子线程每个线程都是独立运行的，线程1不会影响线程2，同理线程2也不会影响线程3，互不影响
if __name__ == '__main__':# target=thread_body() 不是传递参数名称，是调用方法；# args是元组类型，参数只有一个的话，一定要在该元素之后添加逗号，否则会认为是一个字符串类型t1 = threading.Thread(target=thread_body, args = ("三体一：地球往事",), name="下载任务1")t2 = threading.Thread(target=thread_body, args = ("三体二：黑暗森林",), name="下载任务2")t3 = threading.Thread(target=thread_body, args = ("三体三：死神永生",), name="下载任务3")# 启动线程t1.start()t2.start()t3.start()print(f'{threading.current_thread()} 主线程正在执行用户实时操作')

执行结果：
在这里插入图片描述
可以看到的现象就是：主线程都结束了，但是子线程还么有结束，这就会有可能主线程再子线程结束前结束。

需求：主线程需要等子线程全部完成才能结束，所以子线程需要cut line 执行，在python的thread中通过join即可完成这种插队操作，示例代码。

import threading
import time# 下载任务
def thread_body(movie_name):t = threading.current_thread()# 模拟耗时操作for i in range(5):print(f'{t.name} 线程正在下载{movie_name}中')time.sleep(1)# 子线程每个线程都是独立运行的，线程1不会影响线程2，同理线程2也不会影响线程3，互不影响
if __name__ == '__main__':# target=thread_body() 不是传递参数名称，是调用方法；# args是元组类型，参数只有一个的话，一定要在该元素之后添加逗号，否则会认为是一个字符串类型t1 = threading.Thread(target=thread_body, args = ("三体一：地球往事",), name="下载任务1")t2 = threading.Thread(target=thread_body, args = ("三体二：黑暗森林",), name="下载任务2")t3 = threading.Thread(target=thread_body, args = ("三体三：死神永生",), name="下载任务3")# 启动线程t1.start()t2.start()t3.start()# 需求：主线程需要等子线程全部完成才能结束，所以子线程需要cut line 执行t1.join()t2.join()t3.join()print(f'{threading.current_thread()} 主线程正在执行用户实时操作')

t1、t2、t3插队后的执行结果
在这里插入片描述
现象可以说明：join相当于对当前线程产生阻塞现象，阻止当前线程继续向下执行。要想让子线程可以正常执行完毕，需要让子线程插队到主线程之前，保证子线程能完全执行完。
使用案例：例如50个线程下载50张图片，这时候需要每个线程都要结束之后才能结束主线程，此时需要遍历子线程列表，让每一个子线程对象插队到主线程之前执行。

import threading
import time# 下载任务
def thread_body(movie_name):t = threading.current_thread()# 模拟耗时操作for i in range(5):print(f'{t.name} 线程正在下载{movie_name}中')time.sleep(1)# 子线程每个线程都是独立运行的，线程1不会影响线程2，同理线程2也不会影响线程3，互不影响
if __name__ == '__main__':# 创建一个用于存储下载任务子线程的列表download_threads : list[threading.Thread] = list()  #空列表# 参数列表：参数元组类型数据download_agrs = ("三体一：地球往事", "三体二：黑暗森林", "三体三：死神永生")# 创建子线程对象for argument in download_agrs:# 创建子线程download_thread = threading.Thread(target=thread_body, args=(argument,))# 将子线程添加到列表中download_threads.append(download_thread)# 启动子线程download_thread.start()for download_thread in download_threads:# 子线程插队行为download_thread.join()print(f'主线程执行完了')

执行结果
在这里插入图片描述

线程停止：用一个子线程控制另一个子线程的运行状态。

import threading
import time# 全局变量
isRunning = True# 工作体
def working_body():# 死循环while isRunning:print('工作线程正在执行中...')time.sleep(1)print('工作线程执行完毕了...')# 控制线程
def control_body():# 申明全局变量global isRunning# 死循环while isRunning:# 接收用户指令但是没有提示语command = input()# 如果是退出，就修改为false，控制其结束if command == 'exit':isRunning = Falseelse:print(f'{command = }')if __name__ == '__main__':# 主线程# 1.创建子线程working_thread = threading.Thread(target=working_body, name='工作线程')working_thread.start()# 创建一个子线程，用于控制工作线程的执行状态control_thread = threading.Thread(target=control_body, name='控制线程')control_thread.start()print('主线程执行完毕！！')