python:多线程 简单示例

在Python中,多线程编程通常用于执行I/O密集型任务,因为Python的全局解释器锁(GIL)限制了多线程在CPU密集型任务上的性能提升。不过,对于需要同时处理多个I/O操作(如网络请求、文件读写等)的场景,多线程仍然非常有用。

Python的 threading 模块提供了创建和管理线程的基本工具。以下是一个简单的示例,展示了如何使用threading模块来创建和启动多个线程:

import threading
import time# 线程执行的函数
def worker(thread_id, delay):print(f"线程 {thread_id} 开始工作,延迟 {delay} 秒")time.sleep(delay)print(f"线程 {thread_id} 完成工作")# 创建线程列表
threads = []# 启动多个线程
for i in range(5):thread = threading.Thread(target=worker, args=(i, 2))  # 创建一个线程对象threads.append(thread)thread.start()  # 启动线程# 等待所有线程完成
for thread in threads:thread.join()print("所有线程已完成")

在这个示例中,我们定义了一个简单的worker函数,该函数接受线程ID和延迟时间作为参数,模拟线程的工作。然后,我们创建了5个线程,每个线程都会调用worker函数,并传入不同的参数。最后,我们使用join()方法等待所有线程完成。

线程同步
多线程编程中,线程同步是一个重要问题。如果不加以控制,多个线程可能会同时访问共享资源,导致数据竞争和不一致。Python的threading模块提供了多种同步机制,如锁(Lock)、信号量(Semaphore)、条件变量(Condition)等。

以下是一个使用锁的示例:

import threading# 共享资源
counter = 0
lock = threading.Lock()# 线程执行的函数
def increment():global counterfor _ in range(100000):lock.acquire()  # 获取锁counter += 1lock.release()  # 释放锁# 创建线程列表
threads = []# 启动多个线程
for _ in range(10):thread = threading.Thread(target=increment)threads.append(thread)thread.start()# 等待所有线程完成
for thread in threads:thread.join()print(f"最终计数器值: {counter}")

在这个示例中,我们使用了一个锁来保护对共享资源counter的访问。每个线程在修改counter之前都会先获取锁,修改完成后释放锁。这样可以确保同一时间只有一个线程能够访问counter,从而避免了数据竞争。

注意事项
全局解释器锁(GIL):Python的GIL限制了多线程在CPU密集型任务上的性能提升。对于这类任务,可以考虑使用multiprocessing模块来创建多个进程,每个进程都有自己的Python解释器和内存空间,从而绕过GIL的限制。
线程安全:确保线程访问共享资源时是线程安全的,可以使用锁、信号量等同步机制。
死锁:不当使用锁可能会导致死锁问题,即多个线程相互等待对方释放锁,从而永远无法继续执行。要避免死锁,需要确保每个线程都能按照相同的顺序获取锁。
性能开销:创建和销毁线程是有开销的,不要频繁创建和销毁线程。可以使用线程池(如concurrent.futures.ThreadPoolExecutor)来重用线程。
通过合理使用多线程编程,可以显著提高程序的并发性能和响应速度。然而,也需要注意多线程编程带来的复杂性和潜在问题。

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

matlab中高精度计算函数vpa与非厄米矩阵本征值的求解

clear;clc;close all tic %并行设置% delete(gcp(nocreate));%关闭之前的并行 cparcluster(local); c.NumWorkers50;%手动设置线程数(否则默认最大线程为12) parpool(c, c.NumWorkers); %并行设置%w1; u2.5;N30;valstozeros(2*N2,100); v10linspace(-3,3,100).;parfor jj1:leng…

旧服务改造及微服务架构演进

旧服务改造及微服务架构演进 微服务架构演进1.微服务架构2.微服务架构的特点3.单体架构与微服务架构之间的对比4.微服务架构演进历程 旧服务改造1. 微服务拆分的一些通用原则2.微服务拆分策略(1)功能维度拆分策略(2)非功能维度拆分…

springmvc--请求参数的绑定

目录 一、创建项目,pom文件 二、web.xml 三、spring-mvc.xml 四、index.jsp 五、实体类 Address类 User类 六、UserController类 七、请求参数解决中文乱码 八、配置tomcat,然后启动tomcat 1. 2. 3. 4. 九、接收Map类型 1.直接接收Map类型 &#x…

Navicat 17 for Mac 数据库管理软件

Mac分享吧 文章目录 效果一、准备工作二、开始安装1. 双击运行软件,将其从左侧拖入右侧文件夹中,等待安装完毕。2. 应用程序/启动台显示Navicat图标,表示安装成功。 二、运行测试运行后提示:“Navicat Premium.pp”已损坏&#x…

Lombok @Data无法 import 导入的问题解决办法

问题原因:Maven Pom中依赖的Lombok版本与安装在eclipse根目录下的Lombok版本不一致 解决办法:找到Maven Pom依赖版本的Lombok Jar包,执行命令:java -jar lombok-1.18.36.jar,运行如下图,然后安装即可。这样…

对计网大题的一些指正(中间介绍一下CDM的原理和应用)

目录 前言: (1)五层原理体系结构每层功能: 下面是文档的答案: 我在之前的博客里面有介绍过五层原理体系结构, 按理来说,第五层应该是应用层才对,而会话层的功能应该被放到应用层…

RISC-V学习笔记

1.RISC ISA1个基本整数指令集多个可选的扩展指令集,如RV32I表示支持32位整数指令集。I表示基本指令集,M表示整数乘法与除法指令集,A表示存储器原子指令集,F表示单精度浮点指令集,D表示双精度浮点指令集等,C…

SpringBoot入门之创建一个Hello World项目

文章目录 一、使用传统的方式1、创建一个SpringBoot项目2、配置pom.xml文件3、下载Maven依赖4、创建一个Controller类:com.devops.controller.HelloController5、创建一个引导类:com.devops.HelloApplication6、启动项目8、访问80809、完整项目结构 二、…

三、GIT与Github推送(上传)和克隆(下载)

GIT与Github推送(上传)和克隆(下载) 一、配置好SSH二、在Github创建仓库三、git克隆(下载)文件四、git推送(上传)文件到远程仓库 一、配置好SSH Git与Github上传和下载时需要使用到…

深入理解属性抽取:实体内部特征信息的挖掘

目录 前言1. 属性抽取的定义与任务1.1 属性抽取的定义1.2 属性抽取的主要任务 2. 属性抽取的技术方法2.1 基于规则的方法2.2 基于机器学习的方法常用模型特征设计 2.3 基于深度学习的方法常用模型架构优势与挑战 2.4 无监督与弱监督方法 3. 属性抽取面临的挑战与应对策略3.1 挑…

145页PPT智慧矿山整体规划建设方案

本资料收录在【智慧方案文库】知识星球(截止目前共9500份,PPTWORD超过7000份,持续上传中......) 68页PPT丨5G智能矿山解决方案 77页PPT智慧矿山整体规划建设方案

应用架构模式

设计模式 设计模式是指根据通用需求来设计解决方案的模板或蓝图,使用设计模式能够更加有效地解决设计过程中的常见问题。设计模式针对不同的问题域有不同的内涵,主要涉及业务、架构、程序设计等问题域,本文主要讨论架构设计模式。 业务设计模…

以太网ICMP协议(ping指令)——FPGA学习笔记25

--素材来源原子哥 一、IP协议 1、IP简介 IP是Internet Protocol(网际互连协议)的缩写。IP 协议是 TCP/IP 协议簇中的核心协议,它为上层协议提供无状态、无连接、不可靠的服务。IP 协议规定了数据传输时的基本单元和格式 。 IP协议是 OSI 参考模型中网络层…

XIAO ESP32 S3网络摄像头——2视频获取

本文主要是使用XIAO Esp32 S3制作网络摄像头的第2步,获取摄像头图像。 1、效果如下: 2、所需硬件 3、代码实现 3.1硬件代码: #include "WiFi.h" #include "WiFiClient.h" #include "esp_camera.h" #include "camera_pins.h"// 设…

数据看板如何提升决策效率?

数据看板作为一种直观、高效的数据可视化工具,在这一过程中发挥着至关重要的作用。以一家中型制造企业为例,每天面临着生产计划的安排、原材料的采购、产品质量的把控以及市场销售的策略制定等诸多业务场景。在生产线上,需要确保设备的高效运…

javaEE-文件操作和IO-文件

目录 一.什么是文件 1.文件就是硬盘(磁盘)上的文件。 2.计算机中存储数据的设备: 3.硬盘的物理特征 4.树型结构组织和⽬录 5.文件路径 文件路径有两种表示方式: 6.文件的分类 二、java中文件系统的操作 1.File类中的属性: 2.构造方…

【网络安全 | 漏洞挖掘】JS Review + GraphQL滥用实现管理面板访问

未经许可,不得转载。 正文 在映射目标范围后,我发现了一个用于管理的控制台界面,但没有注册功能。 于是我开始尝试: 1、模糊测试注册端点 -> 失败 2、在请求中将登录替换为注册 -> 再次失败 尝试均未奏效后,我决定冷静下来,重新思考方法并利用技术手段。 我观察…

【使用命令配置java环境变量永久生效与脚本切换jdk版本】

java配置环境变量命令与脚本切换jdk版本 新建用户环境变量永久生效 setx JAVA8_HOME "D:\Java\jdk8" setx JAVA17_HOME "d:\Java\jdk-17" setx JAVA_HOME %JAVA8_HOME% setx CLASSPATH ".;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar;"…

RabbitMq的Java项目实践

在现代软件开发中,消息队列(Message Queue,简称MQ)作为一种重要的组件,承担着上下游消息传递和通信的重任。RabbitMQ作为一款流行的开源消息队列中间件,凭借其高可用性、可扩展性和易用性等特点&#xff0c…

《代码随想录》Day25打卡!

《代码随想录》回溯算法:递增子序列 本题的完整题目如下: 本题的完整思路如下: 1.本题使用递归和回溯来求解,所以分为三部: 2.第一步:确定递归函数的返回值和参数:返回值无,参数为原…