目 录CONTENT

文章目录

进程和线程的区别和多线程操作

懿曲折扇情
2022-07-10 / 0 评论 / 6 点赞 / 58 阅读 / 1,276 字 / 正在检测是否收录...
温馨提示:
本文最后更新于 2022-07-10,若内容或图片失效,请留言反馈。部分素材来自网络,若不小心影响到您的利益,请联系我们删除。
广告 广告

一、进程和线程的区别

readme文件

进程:
简单的说:进程就是运行着的程序。
我们写的python程序(或者其他应用程序比如画笔、qq等),运行起来,就称之为一个进程
在windows下面打开任务管理器,里面显示了当前系统上运行着的进程


线程:
而系统中每个进程里面至少包含一个 **线程** 。
线程是操作系统创建的,每个线程对应一个代码执行的数据结构,保存了代码执行过程中的重要的状态信息。
没有线程,操作系统没法管理和维护 代码运行的状态信息。
所以没有创建线程之前,操作系统是不会执行我们的代码的。
我们前面写的Python程序,里面虽然没有创建线程的代码,但实际上,当Python解释器程序运行起来(成为一个进程),
OS就自动的创建一个线程,通常称为主线程,在这个主线程里面执行代码指令。
当解释器执行我们python程序代码的时候,我们的代码就在这个主线程中解释执行。




join通常用于 主线程把任务分配给几个子线程,等待子线程完成工作后,需要对他们任务处理结果进行再处理。
就好像一个领导把任务分给几个员工,等几个员工完成工作后,他需要收集他们提交的报告,进行后续处理。
这种情况,主线程必须子线程完成才能进行后续操作,所以join就是 等待参数对应的线程完成,才返回。

每个线程在 操作共享数据对象之前,都应该 申请获取操作权,也就是 调用该 共享数据对象对应的锁对象的acquire方法。
如果线程A 执行如下代码,调用acquire方法的时候
bankLock.acquire()

二、简单线程理解代码

sup_test.py

# coding=utf-8
"""
    @Project :pachong-master 
    @File    :sup_test.py
    @Author  :gaojs
    @Date    :2022/7/10 17:06
    @Blogs   : https://www.gaojs.com.cn
"""
from threading import Thread
from time import sleep


# 定义一个函数,作为新线程执行的入口函数
def thread_test(arg1, arg2):
    print('子线程 开始')
    print(f'线程函数参数是:{arg1}, {arg2}')
    sleep(5)
    print('子线程 结束')


# 创建Thread 类的实例
thread = Thread(
    # target 参数 指定 新线程要执行的函数
    # 注意,这里指定的函数对象只能写一个名字,不能后面加括号,
    # 如果加括号就是直接在当前线程调用执行,而不是在新线程中执行了
    target=thread_test,
    # 如果 新线程函数需要参数,在 args里面填入参数
    # 注意参数是元组, 如果只有一个参数,后面要有逗号,像这样 args=('参数1',)
    args=('参数1', '参数2')
)
# 执行start 方法,就会创建新线程,
# 并且新线程会去执行入口函数里面的代码。
# 这时候 这个进程 有两个线程了。
# 注意,上面的代码只是创建了一个Thread实例对象, 但这时,新的线程还没有创建。
# 要创建线程,必须要调用 Thread 实例对象的 start方法
thread.start()

# 主线程的代码执行 子线程对象的join方法,
# 就会等待子线程结束,才继续执行下面的代码
thread.join()
print('主线程结束')

三、多线程

mutil_sup.py

# coding=utf-8
"""
    @Project :pachong-master 
    @File    :multi_sup_test.py
    @Author  :gaojs
    @Date    :2022/7/10 17:21
    @Blogs   : https://www.gaojs.com.cn
"""
from threading import Thread, Lock
from time import sleep


# 现在我们程序代码中,有多个线程,并且在这个几个线程中都会去调用 deposit,就有可能同时操作这个bank对象,
# 就有可能出一个线程覆盖另外一个线程的结果的问题。
#
# 这时,可以使用 threading库里面的锁对象 Lock 去保护
bank = {
    'gaojs': 0
}

bankLock = Lock()


# 定义一个函数,作为新线程执行的入口函数
def after_money(theadidx, amount):
    # 操作共享数据前,申请获取锁
    bankLock.acquire()

    balance = bank['gaojs']
    # 执行一些任务,耗费了0.1秒
    sleep(0.1)
    bank['gaojs'] = balance + amount
    # print(bank['gaojs'])
    print(f'第 {theadidx} 个子线程结束')

    # 操作完共享数据后,申请释放锁
    bankLock.release()


theadlist = []
for idx in range(10):
    thread = Thread(
        target=after_money,
        args=(idx, 1)
    )
    thread.start()
    # 把线程对象都存储到 threadlist中
    theadlist.append(thread)

for thread in theadlist:
    thread.join()

print('主线程结束')
print(f'最后我们的账号余额为 {bank["gaojs"]}')
print(bank)

image-1657445779133

6

评论区