一、多线程
每个程序在运行的时候(进程)系统都会为这个进程创建一个线程,这个线程我们叫主线程。
程序员自己创建的线程叫子线程。
多个任务在一个线程中是按顺序一个一个执行的(线程的串行)。
多个线程的任务同时执行。
python通过threading标准库来支持多线程。
1.创建一个线程对象
Thread(target=, args=)
target:需要传一个需要在子线程中执行的函数(类型是function的变量)
args:在子线程中调用target对应的函数的时候,该传什么参数,类型是元组。
t1 = threading.Thread(target=download, args=('阿Q正传',))
2.在子线程中去执行任务
t1.start()
代码
import time
import datetime
import random
import threading
def download(file):
# current_thread()获取当前线程
print(file, threading.current_thread())
print(datetime.datetime.now(), '开始下载:%s' % file)
# sleep(时间):会将当前线程阻塞指定的时间(停指定的时间然后再往后执行)
# 时间单位:秒
time1 =random.randint(5, 10)
time.sleep(time1)
print(datetime.datetime.now(), '下载%s结束' % file, '总共耗时:%d' % time1)
if __name__ == '__main__':
# 1.创建一个线程对象
t1 = threading.Thread(target=download, args=('阿Q正传',))
t2 = threading.Thread(target=download, args=('肖生克的救赎',))
# 2.在子线程中去执行任务
t1.start()
t2.start()
测试结果
二、创建线程2
1.创建线程方式1
直接通过Thread类创建对象,将需要在子线程中执行的函数作为target参数传进去。
2.创建线程方式2
a.写一个自己的类去继承Thread类。
b.重写当前类的run方法,run方法中的任务就是在子线程中执行的任务。
c.创建当前类的对象,就是线程对象。然后调用start去执行线程中的任务。
注意:如果直接调用run方法,run方法中的任务不会在当前的子线程中执行,而是直接在主线程中执行。
代码
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()
测试结果
三、server
代码
import socket
from threading import Thread
class ConversationThread(Thread):
def __init__(self, conversation: 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.121', 8080))
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.121', 8080))
while True:
message = input('>>>')
client.send(message.encode('utf-8'))
message_re = client.recv(1024).decode('utf-8')
print(message_re)