【python学习】Python 线程编程（类内多线程编程）

Python线程编程（类内多线程编程）

文章目录

  • Python线程编程（类内多线程编程）
    • 多线程编程的函数
    • Function级多线程编程
    • class级多线程编程
      • 进阶 类内多线程

多线程可以同时执行一段代码的多个程序。使用多线程可能使程序运行速度更快。

线程和进程不同：可以这样来简单理解，一个程序包含一个或多个进程，一个进程包含一个或多个线程。也就是说程序 > 进程 > 线程。进程之间、线程之间、进程和线程之间可以共享数据。线程也被称为轻量级进程。

线程是操作系统能够运行的最小单位，线程包含在进程中，是进程中的实际运作单位。

Python 线程编程提供了两个模块，即 _thread和threading，其中 _thread是低级模块，threading 是高级模块，它对 _thread模块进行了封装。

import threading
# 或者
from threading import thread

python 多线程编程方法主要有两种，一种是针对Function的，一种是针对Class的。

多线程编程的函数

Thread创建线程Thread(target,args)
方法名说明用法
start启动线程start()
join阻塞直到线程执行结束join(timeout=None)
run用来重载，表示线程活动的方法run()
getName获取线程的名字getName()
setName设置线程的名字setName(name)
is_alive判读线程是否存活is_alive()
setDaemon守护线程setDaemon(True)

Function级多线程编程

Function级别多线程主要是调用Thread模块，Thread模块在Threading库中，Thread本身也是一个类class

该类的接口为

Thread(target, name, args, [kwargs])

target表示一个可调用的对象，可以是一个函数function。

name表示线程的名字，默认创建一个Thread-N格式的唯一名称。

如果target是一个带有参数的函数，则需要使用到args或[kwargs]。

from threading import Thread
t1 = Thread(target=function_name)

上述代码，就是初始化了一个Thread类的对象，其中function_name填写自己的函数名称，这样就新建了一个该函数的线程。

我们可以使用for循环初始化多个线程

from threading import Thread
def task(value):print("I am ", value)time.sleep(3)

一个稍微复杂一点的程序：

list_a = [0, 0, 0, 0, 0, 0]
def task(value):list_a[value] += valueprint("[%s] %s 修改第 %d 个值，修改后值为:%d" % (time.ctime(time.time()), threading.current_thread().name, value, list_a[value]))print("--------------程序开始--------------")
threads_pool = []
for i in range(len(list_a)):t = Thread(target=task,name=i, kwargs={"value": i})   # 初始化6个线程threads_pool.append(t)# 第一个for循环更高级的写法是
threads_pool = [Thread(target=task,name=i, kwargs={"value": i}) for i in range(len(list_a))]# 初始化的线程需要start命令启动，start会自动调用线程中的run命令运行
for t in threads_pool:t.start()for t in threads_pool:t.join()print("---------------程序结束------------")

输出：

--------------程序开始--------------
[Fri Dec  1 21:41:13 2023] Thread-1 修改第 0 个值，修改后值为:0
[Fri Dec  1 21:41:13 2023] 1 修改第 1 个值，修改后值为:1
[Fri Dec  1 21:41:13 2023] 2 修改第 2 个值，修改后值为:2
[Fri Dec  1 21:41:13 2023] 3 修改第 3 个值，修改后值为:3
[Fri Dec  1 21:41:13 2023] 4 修改第 4 个值，修改后值为:4
[Fri Dec  1 21:41:13 2023] 5 修改第 5 个值，修改后值为:5
---------------程序结束------------

注意：看来线程的名字不能被命名为数字0。

上面一个稍微复杂的代码共开了六个线程，每个线程对指定为的list_a数组进行加值的操作，

class级多线程编程

class级多线程编程通过定义一个继承Thread线程类的子类来创建线程。

继承于threading.Thread类的子类，需要对init等方法进行重写：

该段代码来自Python 多线程 | 菜鸟教程 (runoob.com)

import threading
import time
from threading import Thread# list = [0,0,0,0,0,0,0,0,0,0,0,0]
class myThread(threading.Thread):def __init__(self,threadId,name,counter):threading.Thread.__init__(self)self.threadId = threadIdself.name = nameself.counter = counterglobal listlist = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]def run(self):print ("开始线程:",self.name)# 获得锁，成功获得锁定后返回 True# 可选的timeout参数不填时将一直阻塞直到获得锁定# 否则超时后将返回 False# threadLock.acquire()print_time(self.name,self.counter,list.__len__())# 释放锁# threadLock.release()def __del__(self):print (self.name,"线程结束！")
def print_time(threadName,delay,counter):while counter:time.sleep(delay)list[counter-1] += 1print("[%s] %s 修改第 %d 个值，修改后值为:%d" % (time.ctime(time.time()),threadName,counter,list[counter-1]))counter -= 1threadLock = threading.Lock()
threads = []
# 创建新线程
thread1 = myThread(1,"Thread-1",1)
thread2 = myThread(2,"Thread-2",2)
thread3 = myThread(3, "Thread-3",3)
# 开启新线程
thread1.start()
thread2.start()
thread3.start()
# 添加线程到线程列表
threads.append(thread1)
threads.append(thread2)
threads.append(thread3)
# 等待所有线程完成
for t in threads:t.join()
print("主进程结束！")
print("list:", list)

该段代码实现了对Thread继承的一个类，并重写了run()函数。

输出如下：

开始线程: Thread-1
开始线程: Thread-2
开始线程: Thread-3
[Fri Dec  1 21:56:13 2023] Thread-1 修改第 12 个值，修改后值为:1
[Fri Dec  1 21:56:14 2023] Thread-1 修改第 11 个值，修改后值为:1
[Fri Dec  1 21:56:14 2023] Thread-2 修改第 12 个值，修改后值为:2
[Fri Dec  1 21:56:15 2023] Thread-3 修改第 12 个值，修改后值为:3
[Fri Dec  1 21:56:15 2023] Thread-1 修改第 10 个值，修改后值为:1
[Fri Dec  1 21:56:16 2023] Thread-1 修改第 9 个值，修改后值为:1[Fri Dec  1 21:56:16 2023] Thread-2 修改第 11 个值，修改后值为:2[Fri Dec  1 21:56:17 2023] Thread-1 修改第 8 个值，修改后值为:1
[Fri Dec  1 21:56:18 2023] Thread-3 修改第 11 个值，修改后值为:3
[Fri Dec  1 21:56:18 2023] Thread-2 修改第 10 个值，修改后值为:2
[Fri Dec  1 21:56:18 2023] Thread-1 修改第 7 个值，修改后值为:1
[Fri Dec  1 21:56:19 2023] Thread-1 修改第 6 个值，修改后值为:1
[Fri Dec  1 21:56:20 2023] Thread-2 修改第 9 个值，修改后值为:2
[Fri Dec  1 21:56:20 2023] Thread-1 修改第 5 个值，修改后值为:1
[Fri Dec  1 21:56:21 2023] Thread-3 修改第 10 个值，修改后值为:3
[Fri Dec  1 21:56:21 2023] Thread-1 修改第 4 个值，修改后值为:1
[Fri Dec  1 21:56:22 2023] Thread-2 修改第 8 个值，修改后值为:2
[Fri Dec  1 21:56:22 2023] Thread-1 修改第 3 个值，修改后值为:1
[Fri Dec  1 21:56:23 2023] Thread-1 修改第 2 个值，修改后值为:1
[Fri Dec  1 21:56:24 2023] Thread-3 修改第 9 个值，修改后值为:3
[Fri Dec  1 21:56:24 2023] Thread-2 修改第 7 个值，修改后值为:2
[Fri Dec  1 21:56:24 2023] Thread-1 修改第 1 个值，修改后值为:1
[Fri Dec  1 21:56:26 2023] Thread-2 修改第 6 个值，修改后值为:2
[Fri Dec  1 21:56:27 2023] Thread-3 修改第 8 个值，修改后值为:3
[Fri Dec  1 21:56:28 2023] Thread-2 修改第 5 个值，修改后值为:2
[Fri Dec  1 21:56:30 2023] Thread-3 修改第 7 个值，修改后值为:3
[Fri Dec  1 21:56:30 2023] Thread-2 修改第 4 个值，修改后值为:2
[Fri Dec  1 21:56:32 2023] Thread-2 修改第 3 个值，修改后值为:2
[Fri Dec  1 21:56:33 2023] Thread-3 修改第 6 个值，修改后值为:3
[Fri Dec  1 21:56:34 2023] Thread-2 修改第 2 个值，修改后值为:2
[Fri Dec  1 21:56:36 2023] Thread-3 修改第 5 个值，修改后值为:3
[Fri Dec  1 21:56:36 2023] Thread-2 修改第 1 个值，修改后值为:2
[Fri Dec  1 21:56:39 2023] Thread-3 修改第 4 个值，修改后值为:3
[Fri Dec  1 21:56:42 2023] Thread-3 修改第 3 个值，修改后值为:3
[Fri Dec  1 21:56:45 2023] Thread-3 修改第 2 个值，修改后值为:3
[Fri Dec  1 21:56:48 2023] Thread-3 修改第 1 个值，修改后值为:3
主进程结束！
list: [3, 3, 3, 3, 3, 3, 3, 3, 3, 3, 3, 3]
False
Thread-1 线程结束！
Thread-2 线程结束！
Thread-3 线程结束！Process finished with exit code 0

该段代码实现了，开3个线程，每个线程对list数组每个数据进行加1操作。

进阶 类内多线程

有的时候，我们可能在一个类class内部，再实现一个类class，该类被称为内部类，我们希望通过内部类来实现多线程，它的方法和外部类的方法总体比较相似，只要把内部类看作是self的一部分即可。

class Ant_Colony(object):class ant(Thread):def __init__(self, initital_location, ant_id):Thread.__init__(self)self.route = []self.initital_location = initital_locationself.id = ant_iddef run(self):print("开始线程 ant_id: ", self.id)self.calcute_route()def calcute_route(self):offsets = [(-1, 1), (0, 1), (1, 1), (-1, 0), (1, 0), (-1, -1), (0, -1), (1, -1)]cur_pos = self.initital_locationfor offset in offsets:pos_x = cur_pos[0] + offset[0]pos_y = cur_pos[1] + offset[1]if map[pos_x][pos_y] != 0 and pos_x >= 0 and \pos_x < 5 and pos_y >= 0 and pos_y < 5:pheromone[pos_x][pos_y] += 1print("ant_id = %d, pos_x = %d, pos_y = %d" % (self.id, pos_x, pos_y))else:continuedef __del__(self):print("ant_id ", self.id, " 线程结束！")def __init__(self, map, pheronome, ant_num):self.map = mapglobal pheromonepheromone = pheromone# self.pheromone = pheronomeself.ant_num = ant_numself.ants = self._init_ants()def _init_ants(self):return [self.ant([0, 1], i) for i in range(self.ant_num)]def run(self):for ant in self.ants:ant.start()for ant in self.ants:ant.join()self.print()def print(self):print("1")print("类内", pheromone)

输出：

类外： [[0.85956061 0.1645695  0.48347596 0.92102727 0.42855644][0.05746009 0.92500743 0.65760154 0.13295284 0.53344893][0.8994776  0.24836496 0.03017182 0.07244715 0.87416449][0.55843035 0.91604736 0.63346045 0.28325261 0.36536881][0.09223386 0.37251258 0.34742278 0.70517077 0.64850904]]
开始线程 ant_id:  0
ant_id = 0, pos_x = 0, pos_y = 2
ant_id = 0, pos_x = 1, pos_y = 2
ant_id = 0, pos_x = 1, pos_y = 1
ant_id = 0, pos_x = 0, pos_y = 0
ant_id = 0, pos_x = 1, pos_y = 0开始线程 ant_id:  1
ant_id = 1, pos_x = 0, pos_y = 2ant_id = 1, pos_x = 1, pos_y = 2开始线程 ant_id:  
ant_id = 1, pos_x = 1, pos_y = 1
ant_id = 1, pos_x = 0, pos_y = 0
ant_id = 1, pos_x = 1, pos_y = 0
2
ant_id = 2, pos_x = 0, pos_y = 2
ant_id = 2, pos_x = 1, pos_y = 2
ant_id = 2, pos_x = 1, pos_y = 1
ant_id = 2, pos_x = 0, pos_y = 0
ant_id = 2, pos_x = 1, pos_y = 0
1
类内 [[3.85956061 0.1645695  3.48347596 0.92102727 0.42855644][3.05746009 3.92500743 3.65760154 0.13295284 0.53344893][0.8994776  0.24836496 0.03017182 0.07244715 0.87416449][0.55843035 0.91604736 0.63346045 0.28325261 0.36536881][0.09223386 0.37251258 0.34742278 0.70517077 0.64850904]]
类外 [[3.85956061 0.1645695  3.48347596 0.92102727 0.42855644][3.05746009 3.92500743 3.65760154 0.13295284 0.53344893][0.8994776  0.24836496 0.03017182 0.07244715 0.87416449][0.55843035 0.91604736 0.63346045 0.28325261 0.36536881][0.09223386 0.37251258 0.34742278 0.70517077 0.64850904]]
ant_id  2  线程结束！
ant_id  1  线程结束！
ant_id  0  线程结束！

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

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

相关文章

前端常见Linux操作命令

前端常见Linux操作命令

压缩文件 压缩 dist文件为dist.tar.gz tar -czvf dist.tar.gz dist 解压文件 tar -xzvf dist.tar.gz 列出目前工作目录所含的文件及子目录 ls 显示当前目录中的所有文件和目录&#xff0c;包括隐藏文件 ls -a 显示文件和目录的详细信息 它以长格式显示目录内容&#xff0c;包…
阅读更多...
【Python表白系列】无限弹窗，满屏表白代码来啦（完整代码）

【Python表白系列】无限弹窗，满屏表白代码来啦（完整代码）

文章目录 满屏表白代码环境需求完整代码详细分析系列文章 满屏表白代码 环境需求 python3.11.4PyCharm Community Edition 2023.2.5pyinstaller6.2.0&#xff08;可选&#xff0c;这个库用于打包&#xff0c;使程序没有python环境也可以运行&#xff0c;如果想发给好朋友的话需…
阅读更多...
TypeScript 的安装与使用

TypeScript 的安装与使用

npm i typescript -g依赖会安装 tsc 命令 tsc -v初始化 配置 tsc --init生成 tsconfig.json tsconfig.json 配置 要支持 import 模块语法的话 rollup的配置 target 选项需要设置 ES5 module 选项需要改成 es2015 esbuild 的配置 target: ESNext module: ESNext moduleReso…
阅读更多...
rust中动态数组Vec的简单使用

rust中动态数组Vec的简单使用

在Rust中&#xff0c;Vector&#xff08;简称Vec&#xff09;是一个动态数组数据结构&#xff0c;它可以动态地增加或减少其容量。Vec是Rust标准库中的一个常见类型&#xff0c;非常适合用于存储和操作一系列相同类型的值。 Vec其实是一个智能指针&#xff0c;用于在堆上分配内…
阅读更多...
2022年1月14日 Go生态洞察：Go 1.18 新教程探索

2022年1月14日 Go生态洞察：Go 1.18 新教程探索

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
绩效考核管理项目|记录2

绩效考核管理项目|记录2

给界面添加筛选条件并且把搜索功能实现 这段代码写入搜索方法里面就能实现功能。 private void bingdgv(){//筛选项&#xff1a;用户名、职位代码、是否辞职string userName txtUserName.Text.Trim();int baseTypeId (int)base_cbx.SelectedValue;bool isStop isdel_ckb.Che…
阅读更多...
苍穹外卖--订单状态定时处理

苍穹外卖--订单状态定时处理

通过定时任务每分钟检查一次是否存在支付超时订单&#xff08;下单后超过15分钟仍未支付则判定为支付超时订单&#xff09;&#xff0c;如果存在则修改订单状态为“已取消”通过定时任务每天凌晨1点检查一次是否存在“派送中”的订单&#xff0c;如果存在则修改订单状态为“已完…
阅读更多...
【VMware相关】VMware vSphere存储方案

【VMware相关】VMware vSphere存储方案

一、iSCSI存储 参考文档 VMware官方文档&#xff1a;配置iSCSI适配器和存储 华为配置指南&#xff1a;VMware ESXi下的主机连通性指南 1、配置说明 如下图所示&#xff0c;VMware配置iSCSI存储&#xff0c;需要将物理网卡绑定到VMKernel适配器上&#xff0c;之后再将VMKernel适…
阅读更多...
Golang数据类型（数字型）

Golang数据类型（数字型）

Go数据类型&#xff08;数字型&#xff09; Go中数字型数据类型大致分为整数&#xff08;integer&#xff09;、浮点数&#xff08;floating point &#xff09;和复数&#xff08;Complex&#xff09;三种 整数重要概念 整数在Go和Python中有较大区别&#xff0c;主要体现在…
阅读更多...
opencv 图像边框

opencv 图像边框

cv.copyMakeBorder() 图像设置边框或者填充
阅读更多...
mybatis中＜association＞ 和 ＜collection＞

mybatis中＜association＞ 和 ＜collection＞

在 MyBatis 中&#xff0c;<association> 和 <collection> 是用于配置结果映射中关联关系的两个元素。 <association> 用于配置一对一的关联关系&#xff0c;表示两个对象之间的关系是一对一的。例如&#xff0c;一个订单对象关联一个用户对象&#xff0c;使…
阅读更多...
大屏适配方案（vw、vh）

大屏适配方案（vw、vh）

开发大屏主要是两方面的工作&#xff1a; 大屏之关键-前期的自适应适配根据 ui 稿绘制图表&#xff0c;调细节 方案实现方式优点缺点vw vh1.按照设计稿的尺寸&#xff0c;将px按比例计算转为vw和vh1.可以动态计算图表的宽高&#xff0c;字体等&#xff0c;灵活性较高 2.当屏幕…
阅读更多...
PyQt基础_012_对话框类控件QInputDialog

PyQt基础_012_对话框类控件QInputDialog

基本操作 import sys from PyQt5.QtCore import * from PyQt5.QtGui import * from PyQt5.QtWidgets import *class InputdialogDemo(QWidget):def __init__(self, parentNone):super(InputdialogDemo, self).__init__(parent)layout QFormLayout()self.btn1 QPushButton(&qu…
阅读更多...
路由器Beacon帧和低功耗设备DTIM之间的关系

路由器Beacon帧和低功耗设备DTIM之间的关系

1. 路由器发送Beacon帧&#xff1a;路由器周期性地发送Beacon帧&#xff0c;用于广播网络的存在和参数信息。Beacon帧中包含了DTIM周期和DTIM计数器的值。 2. 设备监听Beacon帧&#xff1a;低功耗设备在休眠状态下会定期唤醒来监听路由器发送的Beacon帧。 3. DTIM计数器更新&…
阅读更多...
springboot+java校园自助洗衣机预约系统的分析与设计ssm+jsp

springboot+java校园自助洗衣机预约系统的分析与设计ssm+jsp

洗衣服是每个人都必须做的事情&#xff0c;而洗衣机更成为了人们常见的电器&#xff0c;但是单个洗衣机价格不菲&#xff0c;如果每人都买&#xff0c;就会造成资源的冗余。所有就出现了公用设备&#xff0c;随着时代的发展&#xff0c;很多公用都开始向着无人看守的自助模式经…
阅读更多...
如何访问电脑的组策略编辑器？

如何访问电脑的组策略编辑器？

如何打开组策略 如果我们使用的是 Win 10 系统&#xff0c;如何打开组策略&#xff1f;下面为大家总结了四种打开组策略编辑器的方法。 从搜索框打开 Win 10 策略组怎么打开&#xff1f;一个简单快速的方法就是使用 Windows 自带的搜索栏。我们可以向搜索框中输入“编辑组策…
阅读更多...
halcon中灰度图自动二值化

halcon中灰度图自动二值化

1、首先图片要先形成灰度图&#xff0c;如果下一句是二值化的那就删掉 dev_clear_window() read_image(Image, D:/desktop/tmpp/微信图片_20231201184731.png) * 转为灰度图 rgb1_to_gray(Image, GrayImage) 2、双击图像变量中的GrayImage 3、工具栏点击打开灰度直方图按钮&…
阅读更多...
【数电笔记】基本和复合逻辑运算

【数电笔记】基本和复合逻辑运算

说明&#xff1a; 笔记配套视频来源&#xff1a;B站 基本逻辑运算 1. 与运算 &#xff08;and gate&#xff09; 2. 或运算 &#xff08;or gate&#xff09; 3. 非运算 &#xff08;not gate &#xff09; 复合逻辑运算 1. 与非运算&#xff08;nand&#xff09; 2. 或非运…
阅读更多...
开源镜像站

开源镜像站

百度&#xff08;需要权限&#xff09;&#xff1a;https://mirror.baidu.com/阿里&#xff1a;https://developer.aliyun.com/mirror/腾讯&#xff1a;https://mirrors.cloud.tencent.com/华为&#xff1a;https://mirrors.huaweicloud.com/home清华&#xff1a;https://mirro…
阅读更多...
【动手学深度学习】(七)丢弃法

【动手学深度学习】(七)丢弃法

文章目录 一、理论知识二、代码实现2.1从零开始实现Dropout 【相关总结】np.random.uniform(low&#xff0c;high&#xff0c;size)astypetorch.rand() 一、理论知识 1.动机 一个好的模型需要对输入数据的扰动鲁棒 使用有噪音的数据等价于Tikhonov正则丢弃法&#xff1a;在层…
阅读更多...
最新文章

Copyright @ 2022~2023