一、什么是进程、线程

1.进程：在系统中正在运行的一个应用程序。每个进程之间是独立的，
每个进程都放在一个专用且受保护的内存空间
2.线程：一个进程想要执行任务，必须的有线程（每个进程至少要有一个线程）
一个进程（程序）的所有任务都在线程中执行
一个线程中任务的执行是串行的
3、多线程：一个进程中可以开启多线程，每个线程可以并行（同时）执行不同的任务。
多线程技术可以提高程序的执行效率。

二、多线程的原理

同一时间，CPU只能处理1条线程，只有1条线程在工作（执行）
多线程并发（同时）执行，其实是CPU快速地在多条线程之间调度（切换）
1.操作中的问题：
耗时操作：耗时操作放到主线程中，会阻碍线程的执行。
多个耗时操作都放到一个线程中执行，最终耗时是多个耗时之和
2.怎么解决问题
使用多线程（创建多个线程）

三、多线程技术1

python内置的threading模块，可以支持多线程
所有的进程默认都有一个线程(一般叫这个线程为主线程)，其他的线程叫子线程。
如果想要在进程中添加其他的线程，就创建线程对象。

import threading
import time
def download(file, time1):
    print('开始下载',file)
    time.sleep(time1)
    print(file, '下载结束')
if __name__ == '__main__':
    print('abc')
    # 1.创建线程对象
    """
    target: 需要在子线程中执行的函数
    args: 调用函数的实参列表（参数类型是列表）
    返回值: 线程对象
    """
    t1 = threading.Thread(target=download, args=['爱情公寓', 10])
    # 2.在子线程中执行任务
    t1.start()

    t2 = threading.Thread(target=download, args=['狄仁杰', 5])
    t2.start()
    print('=====')

    # t3 = threading.Thread(target=input, args=['>>>'])
    # t3.start()
    value = input('>>>')
    print('!!!!')

二、多线程技术2

"""
方式2：写一个自己的线程类
1.写一个类，继承自Thread类
2.重写run方法，在里面规定需要在子线程中执行的任务
3.实现在子线程中执行的任务对应的功能，如果需要参数，通过类的对象属性来传值
"""
from threading import Thread
import requests
import re
# 下载数据
class DownloadThread(Thread):
    """下载类"""
    def __init__(self, file_path):
        super().__init__()
        self.file_path = file_path

    def run(self):
        """run方法"""
        """
        1.写在这个方法的内容就是在子线程中执行的内容
        2.这个方法不要直接调用
        """
        print('开始下载')
        response = requests.request('GET', self.file_path)
        data = response.content
        # 获取文件后缀
        suffix = re.search(r'\.\w+$', self.file_path).group()
        with open('./abc'+suffix, 'wb') as f:
            f.write(data)
        print('下载完成...')
if __name__ == '__main__':
    print('=====')
    t1 = DownloadThread('http://10.7.181.117/shareX/Git.exe')
    # 通过start间接调用run方法，run方法中的任务在子线程中执行
    t1.start()
    # 直接调用run方法，run方法中的任务在当前线程中执行
    # t1.run()
    t2=DownloadThread('http://p1.so.qhimgs1.com/t010afefed03d12745d.jpg')
    t2.start()
    print('!!!!!')

三、多线程应用

import socket
from threading import Thread
class CoversationThread(Thread):
    """在子线程中处理不同的客户端会话"""
    """
    python中可以在函数参数的后面加一个冒号，来对参数的类型进行说明
    """
    def __init__(self, conversation:socket.socket, address):
        super().__init__()
        self.conversation = conversation
        self.address = address

    def run(self):
        while True:
            self.conversation.send('你好!'.encode())
            print(self.address,self.conversation.recv(1024).decode(encoding='utf-8'))

if __name__ == '__main__':

    server = socket.socket()
    server.bind(('10.7.181.117', 8080))
    server.listen(512)
    while True:
        conversation, address = server.accept()
        t = CoversationThread(conversation, address)
        t.start()
        # while True:
        #     conversation.send('你好！'.encode())
        #     print(conversation.recv(1024).decode(encoding='utf-8'))

四、join函数

from threading import Thread,currentThread
import time
from random import randint
class Download(Thread):
    def __init__(self, file):
        # 这儿父类的init方法必须调用，否则当前这个创建的对象中就没有新的线程
        super().__init__()
        self.file = file
    def run(self):
        print(currentThread())
        print('开始下载:%s' % self.file)
        time.sleep(randint(5, 10))
        print('%s下载结束' % self.file)

if __name__ == '__main__':

    # time.time(): 获取当前时间-时间戳
    start_time = time.time()
    t1 = Download('最强Z.mp4')
    t1.start()
    t2 = Download('最强A.mp4')
    t2.start()

    print('====')
    # 获取当前线程
    """
    主线程: MainThread
    子线程: Thread-数字（数字从1开始。）
    """
    print(currentThread())
    # 如果一个任务想要在另外一个子线程中的任务执行完成后再执行，就在当前任务前用子线程对象调用join方法
    # 所以join也会阻塞线程，阻塞到对应的子线程中任务执行完为止
    t1.join()
    # t2.join()
    end_time = time.time()
    print('总共消耗时间:%.2f' % (end_time - start_time))

五、知识回复

OSI参考模型：应用层、表示层、会话层、传输层、网络层、数据链路层、物理
TCP/IP协议(栈/簇)：OSI参考模型中涉及的所有的协议
HTTP、TCP和UDP(HTTP是基于TCP的，DNS是基于UDP)
TCP：可靠传输、建立会话、大数据可以分段传输（可以实现长连接）
UDP: 不可靠传输、不会建立会话（不是长连接）、数据只传一次，不会分段
HTTP: 对客户端发送的请求和服务器的响应做了规范和要求。
请求：需要发送请求头和请求体
响应：需要返回响应头和响应体
URL: 统一资源定位符
协议名://主机地址(ip地址,域名)/路径(资源在服务器上的相对路径)
GET和POST: 对参数的传输方式不一样
socket： 写服务端（创建服务端对应的套接字->绑定ip和端口->监听...接受请求，TCP就会建立会话，发送数据和接受数据）
写客户端(创建客户端对应的套接字->连接服务器...发送数据和接受数据)
UDP(自己去学)
requests模块，第三方的库

六、耗时操作

import pygame
from random import randint
import time
"""
1.耗时操作放到主线程中的问题：
耗时操作放到主线程中，会阻塞线程
多个耗时操作都放到一个线程中执行，最终执行的时间是两个耗时操作的时间和

2.怎么解决问题？
使用多线程(创建多个线程)
"""
def rand_color():
    return randint(0, 255),randint(0, 255),randint(0, 255)

def long_time():
    print('耗时操作开始')
    time.sleep(10)
    print('耗时操作结束')

def download(file):
    print('开始下载',file)
    time.sleep(10)
    print(file, '下载结束')

if __name__ == '__main__':
    print('====')
    print(time.time())
    download('狄仁杰')
    download('爱情公寓')
    print(time.time())
    print('!!!')