2018-10-26怎么创多线程

创建线程方式1：
直接通过Thread类创建对象，将需要在子线程中执行的函数作为target参数传进去

创建线程方式2：
a.写一个自己的类去继承Thread类
b.重写当前类的run方法，run中的任务就是在子线程中执行的任务
c.创建当前类的对象, 就是线程对象。然后调用start去执行线程中任务

from threading import Thread,current_thread
import time
from datetime import datetime

# 1.创建线程类
class DownLoadThread(Thread):

    """下载线程类"""
    def __init__(self, file):
        super().__init__()
        self.file = file

    def run(self):
        # 注意：如果需要给run方法中传数据，通过当前类的属性来传
        print('%s开始下载:' % self.file, datetime.now())
        time.sleep(5)
        print('%s下载结束:' % self.file, datetime.now())


# 2.创建线程对象
t1 = DownLoadThread('阿甘正传')
t2 = DownLoadThread('沉默的羔羊')
# 3.通过start去执行run中的任务
"""
注意: 如果直接调用run方法，run方法中的任务不会在当前的子线程中执行
"""
# t1.run()
t1.start()
t2.start()

创建一个多人线程的服务器

import socket
from threading import Thread


class ConversationThread(Thread):
    def __init__(self, conversation: socket.socket, addr):
        super().__init__()
        self.conversation = conversation
        self.addr = addr

    def run(self):
        # 保持通话
        while True:
            # 接收消息
            message_re = self.conversation.recv(1024).decode('utf-8')
            print(self.addr[0], ':', message_re)

            # 发送消息
             #自动回复信息
            message = 'hi %s，你好!' % self.addr[0]
            self.conversation.send(message.encode('utf-8'))



def creat_server():
    server = socket.socket()
    server.bind(('10.7.156.97', 8081))
    server.listen(512)

    # 让服务器一直运行
    while True:
        # 会阻塞线程
        conversation, addr = server.accept()

        # 创建处理这个请求对应的子线程
        t = ConversationThread(conversation, addr)
        t.start()



if __name__ == '__main__':
    creat_server()

客户端client

import socket

client = socket.socket()
client.connect(('10.7.156.97', 8081))

while True:
    message = input('>>>')
    client.send(message.encode('utf-8'))

    message_re = client.recv(1024).decode('utf-8')
    print(message_re)