多线程

多线程技术

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


'''
import threading
import time

def download(file):
    print('开始下载', file)
    time.sleep(5)
    print(file, '下载完成')


if __name__ == '__main__':
    print('abc')
    #1. 创建对象
    '''
    Thread参数
    target: 需要在子线程中执行的函数
    args: 被调用函数的实参列表
    
    
    '''
    t1 = threading.Thread(target=download, args=['洛洛历险记'])

    t2 = threading.Thread(target=download, args=['爱情公寓'])

    #2. 在子线程中执行任务
    t1.start()
    t2.start()

    # download('爱情公寓')
    # download('狄仁杰')
    print('++++++')

abc
开始下载 洛洛历险记
开始下载++++++ 爱情公寓

爱情公寓 下载完成
洛洛历险记 下载完成

多线程技术2

"""__author__ == Jefferson"""
'''
方式2: 写一个自己的线程类
1. 写一个类, 继承自Thread类
2. 重写run方法, 在里面规定需要在子线程中执行的任务
3. 实现在子线程中执行的任务对应的功能, 如果需要参数, 通过类的对象属性来传值

'''
from threading import Thread
from requests import request
import re

#下载数据
class DownloadThread(Thread):
    '''下载类'''

    def __init__(self, file_path):
        super().__init__()
        self.file_path = file_path




    def run(self):
        '''run方法'''
        '''
        写在这个方法中的类容就是在子线程中执行的内容
        这个方法不要直接调用
        '''
        print('开始下载...')
        response = request('GET', self.file_path)
        data = response.content

        #获取文件后缀
        suffix = re.search(r'\.\w+$', self.file_path).group()
        with open('./download'+suffix, 'wb') as file:
            file.write(data)
        print('下载完成')

if __name__ == '__main__':
    t1 = DownloadThread('http://10.7.181.117/shareX/Git.exe')
    #通过start间接调用run方法, run方法中的任务实在子线程中执行
    t1.start()
    #t1.run()直接调用run方法, run方法中的任务在当前线程中执行

    t2 = DownloadThread('http://t2.hddhhn.com/uploads/tu/201707/115/58.jpg')
    t2.start()
    print('=====')

多线程应用

server

"""__author__ == Jefferson"""
import socket
from threading import Thread


class ConversationThread(Thread):
    '''在子线程中处理不同的客户端会话'''

    # python中可以在函数参数的后面加一个冒号, 来对参数的雷聪进行说明
    def __init__(self, conversation: socket.socket, address):
        super().__init__()
        self.conersation = conversation
        self.address = address

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


if __name__ == '__main__':
    server = socket.socket()
    server.bind(('10.7.181.85',8080))
    server.listen()

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

        t = ConversationThread(conversation,address)
        t.start()

client

"""__author__ == Jefferson"""
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函数

"""__author__ == Jefferson"""
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('一人之下.mp4')
    t1.start()

    t2 = Download('balabla.mp3')
    t2.start()

    #如果一个任务想要在另一个子线程中的任务执行完成后再执行, 就在当前任务前用子线程对象调用join方法
    #所以join也会阻塞子线程
    t1.join()
    #t2.join()
    end_time = time.time()
    print('总共消耗时间:%.2f'%(end_time-start_time))

<Download(Thread-1, started 18796)>
开始下载: 一人之下.mp4
<Download(Thread-2, started 6920)>
开始下载: balabla.mp3
balabla.mp3下载结束
一人之下.mp4下载结束
总共消耗时间:10.00