线程与进程
进程就是系统中正在运行的应用程序
每个进程之间相互独立，打开进程会在内存开辟空间来保存程序运行过程中的数据，进程会运行在专用的内存空间里
什么是线程？
一个进程要执行热舞，就必须有线程，，一个进程至少有一个线程进程的所有任务都是在线程中执行的
多线程
import time
import datetime
from random import randint
import threading
每个程序在运行的时候(进程)系统都会为这个进程创建一个线程，我们把这个线程叫做主线程
程序辕自己创建的线程叫做子线程
多个任务在一个线程中是按顺序一个一个执行的
多个线程的任务是同时执行的
怎么创建子线程
python中通过threading标准库来支持多线程
创建线程对象:
threading.Thread(target= , args=)
target: 传一个需要在子线程中执行的函数(类型是function的变量)
args: 在子线程中调用target对应的函数的时候该传什么参数，类型是元组，只有一个元素的时候要加逗号
让子线程执行任务
t1.start()
def down_load(file):
print(file, threading.current_thread())
# 获取当前线程
print(datetime.datetime.now(), '开始下载: %s' % file)
# sleep(时间): 阻塞当前线程指定的时间
time.sleep(randint(5, 10))
print(datetime.datetime.now(), '下载%s结束' % file)
print()
if __name__ == '__main__':
# down_load('肖申克的救赎')
# 创建线程对象
# threading.Thread()
t1 = threading.Thread(target=down_load, args=('阿甘正传',))
t2 = threading.Thread(target=down_load, args=('肖申克的救赎',))
# 子线程执行任务
t1.start()
t2.start()
print(datetime.datetime.now(), '=====')
创建线程
from threading import Thread, current_thread
import datetime
import time
import random
创建线程1:
直接通过threading.Thread类创建对象，将需要在子线程中执行的函数作为target参数传进去
创建线程2:
a.写一个自己的类去继承Thread类
b.实现类的run方法，run方法中的任务就是在子线程中执行的任务
c.创建当前类的对象，就是线程对象，然后调用start去执行线程中的任务
## 1.创建线程类
class DownLoadThread(Thread):
"""下载线程类"""
def __init__(self, file):
# 继承一定要先调用父类的init方法然后再添加自己的属性
super().__init__()
self.file = file
# 重写run方法
def run(self):
# 通过当前类的对象属性或者类的属性来给run传参
print(current_thread())
print(datetime.datetime.now(), '开始下载%s' % self.file)
time_d = random.randint(3, 6)
time.sleep(time_d)
print(datetime.datetime.now(), '下载结束%s' % self.file, '下载时间: %s秒' % time_d)
# 2.创建线程对象
t1 = DownLoadThread('阿甘正传')
t2 = DownLoadThread('肖申克的救赎')
# 3.通过start执行run中的任务
"""注意: 如果直接调用run方法，run方法中的任务实在主线程中执行的，不会在子线程中执行"""
t1.start()
t2.start()
if __name__ == '__main__':
pass
多线程下的socket服务器
"""__author__ = ErYang"""
import socket
from threading import Thread
class ConversationThread(Thread):
def __init__(self, conversation: socket.socket, address):
super().__init__()
self.conversation = conversation
self.address = address
def run(self):
# 保持通话
while True:
# 接收消息
message_re = self.conversation.recv(1024).decode('utf-8')
print('客户端: ', self.address[0], ':', message_re)
# 发送消
message = 'Hi %s, 你好！' % self.address[0]
self.conversation.send(message.encode('utf-8'))
def crate_server():
server = socket.socket()
server.bind(('10.7.156.118', 1027))
server.listen(520)
# 让服务器一直运行
while True:
# 会阻塞线程
conversation, address = server.accept()
# 创建处理这个全球对应的字线程
t = ConversationThread(conversation, address)
t.start()
if __name__ == '__main__':
crate_server()
socket客户端
"""__author__ = ErYang"""
import socket
client = socket.socket()
client.connect(('10.7.156.118', 1027))
# 保持通话
while True:
# 发送消息
message = input(">>> ")
client.send(message.encode('utf-8'))
# 接收消息
message_re = client.recv(1024).decode('utf-8')
print("服务器: ", message_re)
