Python多线程编程

举报
布小禅 发表于 2021/09/17 19:14:04 2021/09/17
【摘要】 多线程编程



☀️ 前言 ☀️

开学 了,开 了,开更了,一起学习吧~~

趁着课余时间学点Python,日后也有一技之长,关注我,我们每天进步一点点。

🙀 作者简介 🙀

大家好,我是布小禅,一个尽力让无情的代码变得生动有趣的IT小白,很高兴能偶认识你,关注我,每天坚持学点东西,我们以后就是大佬啦!

💌一、多线程💌

要先了解进程,线程的区别

  • 进程:

拿电脑举例子的话,进程就是QQ,微信等不同的程序

拿py文件举例子的话,就是你的多几个py文件

  • 线程:

拿电脑举例子的话,就是QQ,微信里你能和好多人一起聊天

拿py文件举例子的话,就是你在py文件里的许多函数

1️⃣多线程编程🌈

何为多线程,通俗的讲就是让你的代码同时干好几件事。

而我们的一个代码文件或者一个项目就是一个进程,而如果我们想提高效率,我们可以多开几个文件进行多进程,也可以在进程中创建多线程(多写几个方法),但是多进程比较耗费资源,所以一般推荐多线程,在代码里,让代码做几个文件做的事。

多线程编程可以让我们的代码拥有更高效率

2️⃣线程的工作过程🏰

使用多线程需要先创建一个或者多个线程

然后让线程调用CPU资源,开始运行

然后运行完毕等待所有线程运行完毕

然后删除资源,结束线程

3️⃣threading模块初识💒

多线程具有无序性

既任务不会按顺序完成

Python内置threading模块能够让我们简单的使用多线程

theading模块也有很多的方法:

  • threading.currentThread(): 返回当前的线程变量。
  • threading.enumerate(): 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前,不包括启动前和终止后的线程。
  • threading.activeCount(): 返回正在运行的线程数量,与len(threading.enumerate())有相同的结果。

除了使用方法外,线程模块同样提供了Thread类来处理线程,Thread类提供了以下方法:

  • run(): 用以表示线程活动的方法。

  • start():

    启动线程活动。

  • join([time]): 等待至线程中止。这阻塞调用线程直至线程的join() 方法被调用中止-正常退出或者抛出未处理的异常-或者是可选的超时发生。

  • isAlive(): 返回线程是否活动的。

  • getName(): 返回线程名。

  • setName(): 设置线程名。

而在我们这个小案例中,并不会使用到别的方法,只会用到一个start方法开启我们的线程,一个join方法阻塞进程。

为什么要阻塞线程:

因为我们的线程是无序的

不一定是哪一个先执行完毕

而join的作用让该线程在执行完毕后等待主线程执行完毕最后再销毁线程

4️⃣多线程编程实战💰

代码需求:

  • 请你定义一个函数遍历三个数组

  • 并执行三次

  • 尽可能少的减小程序运行时间

伪代码流程:

# 代码开始
def 一个遍历函数:
    遍历三个列表
li = []
li2 = []
li3 = []
按照死公式开启多线程
等待程序运行结束

其实就是这么简单,你觉得难的地方都是可以省略的,可以死记硬背的,你只需要知道他的作用,而不需要知道他为什么能做到

代码:

import threading  # 导入模块

# 定义函数
def speak(a, b, c):
    for i, j, l in zip(a, b, c):
        print("我是",i,"\n", "我的博客主页是:", j, "\n", "我们一起组建的Python群号码是:", l)

# 定义函数参数
li = ["雷学委", "孤寒者", "布小禅", "Dragon少年", "yunlord"]
li2 = ['https://blog.csdn.net/geeklevin', 'https://blog.csdn.net/qq_44907926', 'https://blog.csdn.net/m0_52883898', 'https://blog.csdn.net/hhladminhhl', 'https://blog.csdn.net/kobepaul123']
li3 = ["790839397", "790839397", "790839397", "790839397", "790839397"]

# 开启多线程
s1 = threading.Thread(target=speak, args=(li,li2,li3))
s1.start()
s2 = threading.Thread(target=speak, args=(li,li2,li3))
s2.start()
s3 = threading.Thread(target=speak, args=(li,li2,li3))
s3.start()

运行结果:

"""
我是我是  雷学委雷学委  

 我的博客主页是: 我是 我的博客主页是: https://blog.csdn.net/geeklevin 雷学委 https://blog.csdn.net/geeklevin 
 
 
 我们一起组建的Python群号码是: 我的博客主页是: 我们一起组建的Python群号码是: 790839397 https://blog.csdn.net/geeklevin  
790839397 我是

 我是 孤寒者 我们一起组建的Python群号码是: 孤寒者 
 790839397 

我的博客主页是: 我是 我的博客主页是: https://blog.csdn.net/qq_44907926 孤寒者 https://blog.csdn.net/qq_44907926 
 
 
 我们一起组建的Python群号码是: 我的博客主页是: 我们一起组建的Python群号码是: 790839397 https://blog.csdn.net/qq_44907926
790839397 我是

 我们一起组建的Python群号码是: 我是 790839397 布小禅
布小禅 我是

 布小禅 我的博客主页是: 我的博客主页是:
 https://blog.csdn.net/m0_52883898 https://blog.csdn.net/m0_52883898
 我的博客主页是:
 我们一起组建的Python群号码是: https://blog.csdn.net/m0_52883898 我们一起组建的Python群号码是: 790839397

790839397 我是
我们一起组建的Python群号码是: 我是 Dragon少年 790839397 Dragon少年

 我是
 我的博客主页是: Dragon少年 我的博客主页是: https://blog.csdn.net/hhladminhhl
 https://blog.csdn.net/hhladminhhl
 我的博客主页是:
 我们一起组建的Python群号码是: https://blog.csdn.net/hhladminhhl 我们一起组建的Python群号码是: 790839397 790839397


我是 我是 我们一起组建的Python群号码是: yunlord yunlord 790839397


 我是 我的博客主页是: 我的博客主页是: yunlord https://blog.csdn.net/kobepaul123 https://blog.csdn.net/kobepaul123


 我的博客主页是: 我们一起组建的Python群号码是: 我们一起组建的Python群号码是: 790839397 https://blog.csdn.net/kobepaul123
790839397

 我们一起组建的Python群号码是: 790839397
"""

看,我说的对吧,多线程具有无序性,但是他确实提高了你的运行速度。

💰自定义线程类⭐

我们想要自定义线程类的话,就需要继承theading模块的Thead类,并重写其中的run方,每个自定义线程类的都需要重写run方法,而start方法调用的也是run方法

import threading

# 定义执行参数
li = ["雷学委", "孤寒者", "布小禅", "Dragon少年", "yunlord"]
li2 = ['https://blog.csdn.net/geeklevin', 'https://blog.csdn.net/qq_44907926', 'https://blog.csdn.net/m0_52883898', 'https://blog.csdn.net/hhladminhhl', 'https://blog.csdn.net/kobepaul123']
li3 = ["790839397", "790839397", "790839397", "790839397", "790839397"]

# 定义执行函数
def speak(a, b, c):
    for i, j, l in zip(a, b, c):
        print("我是",i,"\n", "我的博客主页是:", j, "\n", "我们一起组建的Python群号码是:", l)

# 自定义线程类
class MyThread(threading.Thread):
    def __init__(self,n):
         threading.Thread.__init__(self)   
         self.n = n
    def run(self):
        print("线程:",self.n, "开启")   # 提示线程已经开启
        speak(li, li2, li3)
        print("线程:",self.n, "关闭")   # 线程进行完的关闭提示
        return super().run()   #重构run函数必须写

# 实例化线程类
s1 = MyThread("thread1")
s2 = MyThread("thread1")

# 开启线程类
s1.start()
s2.start()

# 阻塞线程类
s1.join()
s2.join()

print("全部线程执行完毕,主线程结束")

代码运行效果:

线程: thread1线程:  开启thread1
 我是开启
雷学委我是
雷学委  我的博客主页是:
  https://blog.csdn.net/geeklevin我的博客主页是:
https://blog.csdn.net/geeklevin  我们一起组建的Python群号码是:
  790839397我们一起组建的Python群号码是:
 我是790839397
我是 孤寒者孤寒者

  我的博客主页是:我的博客主页是:  https://blog.csdn.net/qq_44907926https://blog.csdn.net/qq_44907926

  我们一起组建的Python群号码是:我们一起组建的Python群号码是:  790839397790839397

我是我是  布小禅布小禅

  我的博客主页是:我的博客主页是:  https://blog.csdn.net/m0_52883898https://blog.csdn.net/m0_52883898

  我们一起组建的Python群号码是:我们一起组建的Python群号码是:  790839397790839397

我是我是  Dragon少年Dragon少年

  我的博客主页是:我的博客主页是:  https://blog.csdn.net/hhladminhhlhttps://blog.csdn.net/hhladminhhl

  我们一起组建的Python群号码是: 790839397我们一起组建的Python群号码是:
 我是790839397
yunlord我是
yunlord  我的博客主页是:
  https://blog.csdn.net/kobepaul123我的博客主页是:
https://blog.csdn.net/kobepaul123
我们一起组建的Python群号码是:  我们一起组建的Python群号码是:790839397
790839397线程:
 线程:thread1  thread1关闭
关闭
全部线程执行完毕,主线程结束

🌹结语🌹

兴趣是最好的老师,坚持是不变的真理。 学习不要急躁,一步一个脚印,踏踏实实的往前走。 每天进步一点点,日积月累之下,你就会发现自己已经变得很厉害了。

我是布小禅,一枚自学萌新,跟着我每天进步一点点吧!

说了这么多暂时也就够了,那么就告辞吧

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。