一、进程和线程的区别

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)