Python-多线程

一.多线程

python 内置的threading 模块 可以支持多线程

所有的进程默认都有一个线程（一般叫这个线程为主线程）其他的线程叫子线程
如果想要在进程中添加其他对象 就创建线程对象

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

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

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()
    # download('爱情')
    # download('狄仁杰')
    print('=======')

    t3=threading.Thread()
    value=input('>>>>')
    print('!!!!!!')

二.

# from threading import Thread
# import requests
# """
# 方式2：写一个自己的线程类
# 1.下一个类 继承自Thread类
# 2.重写run方法在里面规定需要在子线程中执行的任务
# 3.实现在子线程中执行的任务对应的功能 如果需要参数，通过类的属性来传值
# """
# #下载数据
# class  DownloadThread(Thread):
#     def run(self):
#         """run方法"""
#         """
#         写这个方法的内容就是在子线程中执行的内容
#         这个方法不要直接调用
#
#         """
#         print('开始下载')
#         response=requests.request('GET','http://10.7.181.117/shareX/Git.exe')
#         data=response.content
#         with open('./git.exe','wb')as f:
#             f.write(data)
#         print('下载完成')
#
#
#
# if __name__ == '__main__':
#     print('=======')
#     t1=DownloadThread()
#     #通过start简介调用run方法 run方法中赋任务在子线程中执行
#     t1.start()
#     #直接调用run方法，run方法的任务在当前线程中执行。。、
#     print('!!!!!!!')

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):
        print('开始下载')
        response = requests.request('GET', self.file_path)
        data = response.content

        #获取文件后缀
        # suffix = re.findall(r'([^%/]+\.[a-zA-Z]+)$', self.file_path)[0] #方法二
        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')
    t1.start()
    t2=DownloadThread('https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1533720058151&di=766b5c97653351e805c85881ecaa57d0&imgtype=0&src=http%3A%2F%2Fx.itunes123.com%2Fuploadfiles%2Fb2ab55461e6dc7a82895c7425fc89017.jpg')
    t2.start()
    print('!!!!!!!')

三.多线程的应用

服务端

"""___luopeng___"""

from threading import Thread
import socket
class ConversationThread(Thread):
    """在子线程中处理不同的客户端会话"""
    """
    python中可以在函数参数后面加一个冒号 来对参数的类型进行说明
    """
    def __init__(self,conversation,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.103',8001))
    server.listen(512)

    while True:
        conversation,address=server.accept()
        t=ConversationThread(conversation,address)
        t.start()

        # while True:
        #
            # conversation.send('abc'.encode())
            # print(conversation.recv(1024).decode(encoding='utf-8'))

客户端

"""___luopeng___"""
import socket

if __name__ == '__main__':
    client=socket.socket()
    client.connect(('10.7.181.117',8080))
    while True:
        print(client.recv(1024).decode(encoding='utf-8'))
        message=input('>>>>>')
        client.send(message.encode())

四 join 函数

"""___luopeng___"""
from threading import Thread
import time
from random import randint
class Download(Thread):
    def __init__(self,file):
        #这儿的父类的init方法必须调用，否则当前这个创建的对象中就没有新的线程
        super().__init__()
        self.file=file


    def run(self):
        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')
    t1.start()
    t2=Download('最强 A')
    t2.start()

    print('====')
    # print(currentTread())


    #如果一个任务想要在另外一个子线程中的任务执行完成后再执行，
        # 就在当前任务前用子线程对象调用join方法
    #join也会阻塞线程 阻塞到对应的子线程中任务执行完为止
    t1.join()
    #t2.join()
    end_time=time.time()
    print('总时间：%.2f'%(end_time - start_time))