一些基础概念
进程：一个程序的执行实例（本质上是资源的集合）
多进程：每个进程都是由父进程提供的。每启动一个子进程就从父进程克隆一份数据，但是进程之间的数据本身是不能共享的
线程：操作系统能够进行运算调度的最小单位（串行）
多线程：进程内并行的多个线程（实质上是CPU快速切换造成的假象）
进程与线程区别
1.同一个进程中的线程共享同一内存空间，但是进程之间是独立的。
2.同一个进程中的所有线程的数据是共享的（进程通讯），进程之间的数据是独立的。
3.对主线程的修改可能会影响其他线程的行为，但是父进程的修改（除了删除以外）不会影响其他子进程。
4.线程是一个上下文的执行指令，而进程则是与运算相关的一簇资源。
5.同一个进程的线程之间可以直接通信，但是进程之间的交流需要借助中间代理来实现。
6.创建新的线程很容易，但是创建新的进程需要对父进程做一次复制。
7.一个线程可以操作同一进程的其他线程，但是进程只能操作其子进程。
8.线程启动速度快，进程启动速度慢（但是两者运行速度没有可比性）。
http://www.cnblogs.com/whatisfantasy/p/6440585.html
https://www.jianshu.com/p/1d02caba97ab
耗时操作
1.耗时操作放到主线程中的问题：
耗时操作放到主线程中，会阻塞线程
多个耗时操作都放到一个线程中执行，最终执行的时间是两个耗时操作的时间和
2.怎么解决问题？
使用多线程(创建多个线程)
import pygame
from random import randint
import time
def rand_color():
return randint(0, 255),randint(0, 255),randint(0, 255)
def long_time():
print('耗时操作开始')
time.sleep(10)
print('耗时操作结束')
def download(file):
print('开始下载',file)
time.sleep(10)
print(file, '下载结束')
if __name__ == '__main__':
print('====')
print(time.time())
download('狄仁杰')
download('爱情公寓')
print(time.time())
print('!!!')
运行结果：
====
1533728912.7237718
开始下载 狄仁杰
狄仁杰 下载结束
开始下载 爱情公寓
爱情公寓 下载结束
1533728932.734618
!!!
多线程
python内置的threading模块，可以支持多线程
所有的进程默认都有一个线程(一般叫这个线程为主线程)，其他的线程叫子线程
如果想要在进程中添加其他的线程，就创建线程对象
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(target=input, args=['>>>'])
# t3.start()
value = input('>>>')
print('!!!!')
方式2：写一个自己的线程类(常用)
1.写一个类，继承自Thread类
2.重写run方法，在里面规定需要在子线程中执行的任务
3.实现在子线程中执行的任务对应的功能，如果需要参数，通过类的对象属性来传值
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):
"""run方法"""
"""
1.写在这个方法的内容就是在子线程中执行的内容
2.这个方法不要直接调用
"""
print('开始下载')
response = requests.request('GET', self.file_path)
data = response.content
# 获取文件后缀
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')
# 通过start间接调用run方法，run方法中的任务在子线程中执行
t1.start()
# 直接调用run方法，run方法中的任务在当前线程中执行
# t1.run()
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('!!!!!')
应用
利用多线程实现服务器同时连接多个客户端（长连接）
import socket
from threading import Thread
class CoversationThread(Thread):
"""在子线程中处理不同的客户端会话"""
"""
python中可以在函数参数的后面加一个冒号，来对参数的类型进行说明
"""
def __init__(self, conversation:socket.socket, 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(('*.*.*.*', 8080))
server.listen(512)
while True:
conversation, address = server.accept()
t = CoversationThread(conversation, address)
t.start()
# while True:
# conversation.send('你好！'.encode())
# print(conversation.recv(1024).decode(encoding='utf-8'))
网友评论