python创建线程和结束线程

👽发现宝藏

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。【点击进入巨牛的人工智能学习网站】。

python创建线程和结束线程

在 Python 中，线程是一种轻量级的执行单元，允许我们在程序中同时执行多个任务。线程的创建和结束是多线程编程中的核心概念之一。在本文中，我们将学习如何使用 Python 创建线程，并探讨如何优雅地结束线程。

创建线程

Python 中创建线程非常简单，可以使用 threading 模块来实现。下面是一个简单的例子：

import threading
import timedef print_numbers():for i in range(1, 6):print(i)time.sleep(1)# 创建线程
thread = threading.Thread(target=print_numbers)# 启动线程
thread.start()# 主线程等待子线程执行完成
thread.join()print("线程执行完成！")

在这个例子中，我们创建了一个名为 print_numbers 的函数，该函数用于打印 1 到 5 的数字。然后，我们使用 threading.Thread 类创建了一个新的线程，并指定了要执行的目标函数。最后，通过调用 start() 方法启动线程，通过 join() 方法等待线程执行完成。

结束线程

结束线程通常是为了让程序在不需要线程继续执行时能够正常退出，或者在特定条件下终止线程的执行。在 Python 中，线程是无法直接终止的，但是可以通过设置标志位或者发送信号的方式让线程自行退出。下面是一个简单的例子：

import threading
import time# 全局标志位，控制线程执行
is_running = Truedef count_numbers():i = 1while is_running:print(i)i += 1time.sleep(1)# 创建线程
thread = threading.Thread(target=count_numbers)# 启动线程
thread.start()# 主线程等待一段时间后修改标志位，结束线程
time.sleep(5)
is_running = Falseprint("等待线程执行完成...")
thread.join()print("线程执行完成！")

在这个例子中，我们创建了一个名为 count_numbers 的函数，该函数会不断地打印数字，并通过一个全局变量 is_running 控制线程的执行。在主线程中，我们等待了 5 秒后将 is_running 设置为 False，从而让线程自行退出。

安全结束线程

除了设置标志位的方式外，有时候我们可能需要更加安全和可靠地结束线程。Python 中的线程并没有提供直接的方法来强制终止线程，但可以使用一些技巧来安全地结束线程，比如使用 Thread 对象的 Event。

下面是一个使用 Event 来结束线程的示例：

import threading
import time# 创建 Event 对象
stop_event = threading.Event()def count_numbers():i = 1while not stop_event.is_set():print(i)i += 1time.sleep(1)# 创建线程
thread = threading.Thread(target=count_numbers)# 启动线程
thread.start()# 主线程等待一段时间后设置 Event，结束线程
time.sleep(5)
stop_event.set()print("等待线程执行完成...")
thread.join()print("线程执行完成！")

在这个例子中，我们创建了一个 Event 对象 stop_event，线程在每次循环中检查该事件是否被设置。在主线程中，我们等待了 5 秒后设置了 stop_event，从而结束了线程的执行。

异常处理

在线程中，异常的处理也是一个重要的问题。如果线程中发生了异常而没有处理，整个线程可能会意外终止。因此，在线程中要使用 try-except 语句来捕获异常，并进行适当的处理。

下面是一个简单的例子：

import threading
import timedef task():try:# 这里是线程执行的任务print("任务开始...")time.sleep(3)raise Exception("人为抛出异常")except Exception as e:print(f"捕获到异常：{e}")# 创建线程
thread = threading.Thread(target=task)# 启动线程
thread.start()# 主线程等待线程执行完成
thread.join()print("线程执行完成！")

在这个例子中，线程中的任务抛出了一个异常，但由于我们在 task 函数中使用了 try-except 语句，因此异常被捕获并打印出来，而线程并没有意外终止。

使用线程池管理线程

在实际开发中，如果需要频繁地创建和销毁线程，可能会导致性能下降。为了更有效地管理线程，可以使用线程池来重用线程对象。Python 提供了 concurrent.futures 模块，其中的 ThreadPoolExecutor 类可以帮助我们轻松地管理线程池。

下面是一个使用线程池的例子：

from concurrent.futures import ThreadPoolExecutor
import timedef task(n):print(f"任务 {n} 开始...")time.sleep(2)print(f"任务 {n} 完成！")# 创建线程池
with ThreadPoolExecutor(max_workers=3) as executor:# 提交任务给线程池执行for i in range(1, 6):executor.submit(task, i)print("所有任务执行完成！")

在这个例子中，我们使用 ThreadPoolExecutor 创建了一个最大工作线程数为 3 的线程池。然后，我们提交了 5 个任务给线程池执行。线程池会自动管理线程的创建和销毁，以及任务的调度。

使用 threading.Thread 的子类

除了直接使用 threading.Thread 类外，我们还可以通过继承 threading.Thread 创建自定义的线程类。这样做可以更好地组织代码，并且可以在子类中重写 run() 方法来定义线程执行的逻辑。

下面是一个简单的例子：

import threading
import timeclass MyThread(threading.Thread):def __init__(self, name):super().__init__()self.name = namedef run(self):print(f"{self.name} 线程开始执行...")time.sleep(3)print(f"{self.name} 线程执行完成！")# 创建线程实例并启动
thread1 = MyThread("Thread 1")
thread2 = MyThread("Thread 2")thread1.start()
thread2.start()# 等待线程执行完成
thread1.join()
thread2.join()print("所有线程执行完成！")

在这个例子中，我们定义了一个 MyThread 类，继承自 threading.Thread，并重写了 run() 方法来定义线程执行的逻辑。然后，我们创建了两个 MyThread 的实例，并启动了这两个线程。

线程同步与共享资源

在多线程编程中，经常会遇到多个线程同时访问共享资源的情况。为了避免竞争条件和数据不一致的问题，需要使用线程同步机制来保护共享资源。

使用锁（Lock）

锁是最常见的线程同步机制之一，Python 中的 threading.Lock 类可以用来创建锁对象。在访问共享资源之前，线程可以通过调用 acquire() 方法获取锁，访问完成后再调用 release() 方法释放锁。

下面是一个使用锁来保护共享资源的例子：

import threadingshared_resource = 0
lock = threading.Lock()def update_shared_resource():global shared_resourcefor _ in range(100000):lock.acquire()shared_resource += 1lock.release()# 创建多个线程来更新共享资源
threads = []
for _ in range(5):t = threading.Thread(target=update_shared_resource)threads.append(t)t.start()# 等待所有线程执行完成
for t in threads:t.join()print("共享资源的值为:", shared_resource)

在这个例子中，我们创建了一个名为 shared_resource 的共享变量，然后使用 threading.Lock 创建了一个锁对象 lock。在 update_shared_resource 函数中，我们使用锁来保护对 shared_resource 的访问，从而避免了多个线程同时修改共享资源的问题。

使用条件变量（Condition）

条件变量是另一种常见的线程同步机制，Python 中的 threading.Condition 类可以用来创建条件变量对象。条件变量通常与锁结合使用，可以在满足特定条件时通知等待的线程。

下面是一个使用条件变量来实现生产者-消费者模式的例子：

import threading
import timeMAX_ITEMS = 5
items = []
condition = threading.Condition()def producer():for i in range(10):time.sleep(1)with condition:if len(items) >= MAX_ITEMS:print("仓库已满，生产者等待...")condition.wait()print("生产者生产一个商品")items.append(i)condition.notify()def consumer():for i in range(10):time.sleep(1.5)with condition:while not items:print("仓库为空，消费者等待...")condition.wait()item = items.pop(0)print(f"消费者消费了商品 {item}")condition.notify()# 创建生产者和消费者线程并启动
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)producer_thread.start()
consumer_thread.start()# 等待线程执行完成
producer_thread.join()
consumer_thread.join()print("所有商品已被生产和消费完毕！")

在这个例子中，我们使用了条件变量 condition 来实现生产者-消费者模式。生产者线程在仓库满时等待，消费者线程在仓库空时等待，并在生产或消费完成后通过 notify() 方法通知等待的线程。

使用队列实现线程间通信

除了使用锁和条件变量等同步机制外，还可以使用队列来实现线程间的安全通信。Python 中的 queue.Queue 类提供了线程安全的队列实现，可以在多个线程之间安全地传递数据。

下面是一个使用队列实现生产者-消费者模式的例子：

import threading
import queue
import timeMAX_ITEMS = 5
queue = queue.Queue(MAX_ITEMS)def producer():for i in range(10):time.sleep(1)try:queue.put(i, block=True, timeout=1)print("生产者生产一个商品")except queue.Full:print("仓库已满，生产者等待...")def consumer():for i in range(10):time.sleep(1.5)try:item = queue.get(block=True, timeout=1)print(f"消费者消费了商品 {item}")except queue.Empty:print("仓库为空，消费者等待...")# 创建生产者和消费者线程并启动
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)producer_thread.start()
consumer_thread.start()# 等待线程执行完成
producer_thread.join()
consumer_thread.join()print("所有商品已被生产和消费完毕！")

在这个例子中，我们使用了 queue.Queue 类来实现生产者-消费者模式。生产者线程通过 put() 方法向队列中添加商品，消费者线程通过 get() 方法从队列中取出商品。当队列已满时，生产者线程会等待；当队列为空时，消费者线程会等待。

使用队列实现线程间通信的好处在于，它提供了一种简单而安全的方式来传递数据，避免了显式的锁和条件变量的使用。

定时结束线程

有时候，我们希望线程在一定时间内执行完毕或者超时退出。Python 中可以利用定时器来实现这一功能。定时器可以在指定的时间后触发一个事件，我们可以利用这个特性来控制线程的执行时间。

下面是一个使用定时器结束线程的例子：

import threading
import timedef task():print("线程开始执行...")time.sleep(3)  # 模拟线程执行时间print("线程执行完成！")# 创建线程
thread = threading.Thread(target=task)# 启动线程
thread.start()# 定时器，3秒后设置线程结束标志
def set_thread_finished():print("定时器触发，设置线程结束标志...")thread.finished = Truetimer = threading.Timer(3, set_thread_finished)
timer.start()# 主线程等待线程执行完成
thread.join()print("线程执行完成！")

在这个例子中，我们创建了一个定时器 timer，在 3 秒后触发 set_thread_finished 函数，该函数设置了线程的结束标志。线程在执行时会检查结束标志，如果标志被设置，则提前退出。这样就实现了在指定时间后结束线程的功能。

使用 threading.Event 实现线程等待

除了定时器，我们还可以使用 threading.Event 来实现线程的等待和超时退出。Event 是线程间通信的一种机制，可以用来设置信号、等待信号等操作。

下面是一个使用 Event 实现线程等待的例子：

import threading
import time# 创建 Event 对象
event = threading.Event()def task():print("线程开始执行...")event.wait(3)  # 等待事件触发，超时时间为3秒if event.is_set():print("事件被触发，线程执行完成！")else:print("超时退出，线程执行未完成！")# 创建线程
thread = threading.Thread(target=task)# 启动线程
thread.start()# 等待一段时间后设置事件
time.sleep(2)
print("等待2秒后设置事件...")
event.set()# 主线程等待线程执行完成
thread.join()print("线程执行完成！")

在这个例子中，线程在执行时等待事件的触发，如果在3秒内事件被设置，则线程执行完成；否则，线程会在超时后退出。这样就实现了在指定时间内结束线程的功能。

总结

在本文中，我们探讨了在 Python 中创建线程、结束线程以及线程管理的多种方法。我们从创建线程的基础开始，介绍了使用 threading 模块创建线程的方法，并展示了如何优雅地结束线程。接着，我们深入讨论了线程同步与共享资源的问题，介绍了使用锁、条件变量和队列等机制来保护共享资源、实现线程间通信的方法。然后，我们探讨了如何使用定时器和事件来实现线程的定时结束和超时退出，从而更灵活地控制线程的执行时间。

总的来说，本文全面介绍了多线程编程中的关键概念和技术，并提供了丰富的代码示例来帮助读者更好地理解和应用这些技术。通过合理地使用线程管理和同步机制，我们可以编写出高效、可靠的多线程程序，更好地利用计算资源，提高程序的性能和可维护性。希望本文对读者在 Python 多线程编程方面有所帮助。

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/2979614.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

Mysql 存在多条数据，按时间取最新的那一组数据

Mysql 存在多条数据，按时间取最新的那一组数据

1、数据如下，获取每个用户最近的一次登录数据 思路1：order by group by 先根据UserIdLogInTime排序，再利用Group分组，即可得到每个User_Id的最新数据。 1 SELECT * FROM login_db l ORDER BY l.user_id, l.login_time DESC; 排…
阅读更多...
【Linux】实现一个进度条

【Linux】实现一个进度条

我们之前也学了gcc/vim/make和makefile，那么我们就用它们实现一个进度条。 在实现这个进度条之前，我们要先简单了解一下缓冲区和回车和换行的区别 缓冲区其实就是一块内存空间，我们先看这样一段代码 它的现象是先立马打印，三秒后程…
阅读更多...
使用表格法插入公式和编号

使用表格法插入公式和编号

如何将公式和编号优雅地插入到论文当中呢？ 首先插入一个1行2列的表格 调整一下 输入公式方法一：感觉墨迹公式挺好用的，word自带的 输入公式方法二：图片转LATEX代码 这个方法更快 分享一个公式识别网站 图片识别得到LATEX代码&…
阅读更多...
惠海H6212L DCDC同步降压芯片IC 24V30V36V48V转3.3V5V12V3A大电流方案 带线损

惠海H6212L DCDC同步降压芯片IC 24V30V36V48V转3.3V5V12V3A大电流方案 带线损

同步降压芯片IC 24V30V36V48V转3.3V5V12V3A大电流方案是一种电源管理方案，它采用同步整流技术，将较高的输入电压（如24V、30V、36V、48V）转换为较低的输出电压（如3.3V、5V、12V），并提供高达3A的大…
阅读更多...
代码随想录训练营Day 29|Python|Leetcode|● 860.柠檬水找零 ● 406.根据身高重建队列 ● 452. 用最少数量的箭引爆气球

代码随想录训练营Day 29|Python|Leetcode|● 860.柠檬水找零 ● 406.根据身高重建队列 ● 452. 用最少数量的箭引爆气球

860.柠檬水找零 在柠檬水摊上，每一杯柠檬水的售价为 5 美元。顾客排队购买你的产品，（按账单 bills 支付的顺序）一次购买一杯。 每位顾客只买一杯柠檬水，然后向你付 5 美元、10 美元或 20 美元。你必须给每个顾客正确…
阅读更多...
openGauss学习笔记-269 openGauss性能调优-TPCC性能调优测试指导-数据库服务端及客户端绑核

openGauss学习笔记-269 openGauss性能调优-TPCC性能调优测试指导-数据库服务端及客户端绑核

文章目录 openGauss学习笔记-269 openGauss性能调优-TPCC性能调优测试指导-数据库服务端及客户端绑核269.1 安装openGauss数据库269.2 停止数据库269.3 使用gs_guc工具修改数据库端口、IP等269.4 使用gs_guc工具设置如下参数269.5 执行如下命令以绑核方式启动服务端数据库269.6…
阅读更多...
【计算机毕业设计】药品销售系统产品功能介绍——后附源码

【计算机毕业设计】药品销售系统产品功能介绍——后附源码

🎉**欢迎来到我的技术世界！**🎉 📘 博主小档案： 一名来自世界500强的资深程序媛，毕业于国内知名985高校。 🔧 技术专长： 在深度学习任务中展现出卓越的能力，包括但不限于…
阅读更多...
手把手教数据结构与算法：有序线性表设计

手把手教数据结构与算法：有序线性表设计

问题描述 设计一个有序线性表类，要求完成初始化，插入和遍历功能，使得表内元素实现有序排列（从小到大）。同时实现合并功能，使得两个线性表能够合并为一个线性表（可能存在重复元素）。…
阅读更多...
半导体存储器整理

半导体存储器整理

半导体存储器用来存储大量的二值数据，它是计算机等大型数字系统中不可缺少的组成部分。按照集成度划分，半导体存储器属于大规模集成电路。 目前半导体存储器可以分为两大类： 只读存储器（ROM，Read Only Memory&#xff…
阅读更多...
ThingsBoard服务端使用RPC通过网关给设备发送消息

ThingsBoard服务端使用RPC通过网关给设备发送消息

一、概述 1、发送服务器端网关RPC 二、案例： 1、建立设备与网关之间的通讯 2、查看设备和网关是否在线状态啊 3、通过 仪表盘，创建设备A的模拟RPC调用的窗口链接 4、在客户端的网关设备上订阅RPC网关的主题信息 5、通过服务端的窗口，发…
阅读更多...
DaPy：实现数据分析与处理

DaPy：实现数据分析与处理

DaPy：实现数据分析与处理 DaPy是一个用于数据分析和处理的Python库，它提供了一系列强大的工具和功能，使开发者能够高效地进行数据清洗、转换和分析。本文将深入解析DaPy库的特点、功能以及使用示例，帮助读者了解如何利用DaPy库处理…
阅读更多...
Oracle使用内部包自定义创建表空间和用户

Oracle使用内部包自定义创建表空间和用户

如果之前有类似的表空间，可以使用dbms自动生成对应的表空间和数据文件 select dbms_metadata.get_ddl(TABLESPACE,ts.tablespace_name) from dba_tablespaces ts; 可以使用类似的 SQL> set echo off SQL> spool /data/logs/create_tablespace.log SQL> select dbms…
阅读更多...
【详细实现】v1.0 随机点名应用

【详细实现】v1.0 随机点名应用

1.引言 前面对这个应用的功能做了详细的分析（长什么样、能干什么），以先这样对一个项目最开始的分析成为需求分析，需求分析之后就是设计阶段。 那么一般的项目，在设计阶段都需要干什么呢？在需求分析阶段确定…
阅读更多...
世界读书日，正在为管理团队而烦恼？听书690本的我最推荐的3本书

世界读书日，正在为管理团队而烦恼？听书690本的我最推荐的3本书

前言 今天是世界读书日，如果你是新晋管理者，或者将来想晋升管理这条线。可以参考以下实操性很强，很容易上手的三本团队书籍。 Top3书籍：《10人以下小团队管理手册》《所有问题，七步解决》《可复制领导力》 Top1&#…
阅读更多...
数仓建模—数据语义层

数仓建模—数据语义层

数仓建模—数据语义层 什么是语义层 如今，企业产生大量数据，需要以正确的方式进行分析才能做出重要决策。数据可能来自多个来源并采用不同的格式，这使得清楚地了解其含义和重要性成为一项挑战。这就是语义层的用武之地。 语义层存在于数据仓库和最终用户使用的应用程序之间…
阅读更多...
【计算机毕业设计】jspm医院门诊挂号系统——后附源码

【计算机毕业设计】jspm医院门诊挂号系统——后附源码

🎉**欢迎来到琛哥的技术世界！**🎉 📘 博主小档案： 琛哥，一名来自世界500强的资深程序猿，毕业于国内知名985高校。 🔧 技术专长： 琛哥在深度学习任务中展现出卓越的能力&a…
阅读更多...
【深度学习（1）】研0和研1如何上手深度学习及定方向

【深度学习（1）】研0和研1如何上手深度学习及定方向

深度学习（1） 基础部分书籍鱼书 (理论部分) 视频课程我是土堆（代码部分） 提升部分李沐的动手学深度学习李沐老师的书 定方向网站： paperwithcode谷歌学术找论文 基础部分 书籍 鱼书 (理论部分) 适合入门，…
阅读更多...
探索 去中心化的Web3.0

探索 去中心化的Web3.0

随着区块链技术的日益成熟和普及，Web3（Web 3.0）已经成为一个无法忽视的趋势。Web3不仅仅是一个技术概念，更是一个去中心化、透明、用户数据拥有权归还给用户的互联网新时代。在这篇文章中，我们将深入探讨Web3技术的核心…
阅读更多...
如何启用启用WordPress调试模式

如何启用启用WordPress调试模式

最近我们的WordPress网站在访问时，经常出现打不开的现象，我们向主机提供商Hostease咨询后，他们提到这是由于WordPress的某个插件导致的问题，我们在将插件版本升级至最新后，这个问题就消失了。为了方便后续的检查&#…
阅读更多...
如何判断客户需求能不能做出来产品？

如何判断客户需求能不能做出来产品？

在做G端产品的过程中，为了让产品可以符合客户实际需求，我们需要经历客户需求调研的这个环节。那么，需求收集后，我们要从什么维度判断客户的需求是否真的可以产品化呢？ 我们做G端产品，新产品的方向几乎100%来自于政策。所以才会有“政策带来产品，产品催生政绩”。 可就算…
阅读更多...
最新文章

Copyright @ 2022~2023