外贸五金网站建设,第一素材网,wordpress外链图片本地化,西安企业微信服务商目录
一、线程与进程很简单的介绍
1.1 线程与进程的区别
二、多进程Process
2.1 多进程与多线程的区别
2.2 多进程为啥要使用队列
2.3 控制进程运行顺序
2.3.1 join #xff0c;
2.3.1 daemon 守护进程 2.4 进程id
2.5 进程 存活状态is_alive()
2.5 实现自定义多…目录
一、线程与进程很简单的介绍
1.1 线程与进程的区别
二、多进程Process
2.1 多进程与多线程的区别
2.2 多进程为啥要使用队列
2.3 控制进程运行顺序
2.3.1 join
2.3.1 daemon 守护进程 2.4 进程id
2.5 进程 存活状态is_alive()
2.5 实现自定义多进程类
三、多线程 threading
3.1 线程锁
四、线程池、进程池
4.1 线程池
4.2 进程池
4.2.1 pool.map( func, iterable)
4.2.2 pool.map_async( func, iterable)
4.2.3 pool.apply(self, func, args(), kwds{})
4.2.4 pool.apply_async(self, func, args(), kwds{})
五、协程
六、进程的相关知识
6.1 进程的各种状态
6.2 上下文切换 一、线程与进程很简单的介绍 多任务的实现方式
多进程、多线程、协程 串行运行
运行完命令1之后再运行命令2。
在linux 中 ,串行多条命令用
我们在启动tomcat时一般是需要启动同时观察日志输出的。
sh startup.sh tail -f ../logs/catalina.out 并行运行
命令1与命令2同时运行。
apt install xx apt install yy
同时下载xx 与 yy 1.1 线程与进程的区别
1、线程与进程最大的区别在于线程是调度的基本单位而进程则是资源拥有的基本单位。
2、资源主要是内存资源进程占用内存资源线程使用的资源是进程的。
3、切换
进程与进程间的切换更消耗时间。
线程与线程之间切换速度比较快因为线程之间使用的资源都是同一个进程的。 二、多进程Process
举例多进程下载场景
一个下载场景我们需要从网站上下载大量的图片。比如有一万条数据。我们需要将这一万张图片下载下来。
我们将大量图片的下载链接放到队列里。
# 多进程
from multiprocessing import Process,Queuedef download(q: Queue):while True:url q.get()print(url)if q.empty():breakif __name__ __main__:tasks Queue()tasks.put(http://aaa.jpg)tasks.put(http://bbb.jpg)# target 函数的名字# args 函数所需的参数这里是元组元组里只有一个元素时也许需要加,p1 Process(targetdownload,args(tasks,)) # 创建进程1p2 Process(targetdownload, args(tasks,)) # 创建进程1p1.start() # 启动进程1p2.start() # 启动进程2
注意
1、# target 函数的名字 # args 函数所需的参数这里是元组元组里只有一个元素时也许需要加逗号 # target 函数的名字# args 函数所需的参数这里是元组元组里只有一个元素时也许需要加,p1 Process(targetdownload,args(tasks,)) # 创建进程1p2 Process(targetdownload, args(tasks,)) # 创建进程1
2、我们这里启动了2个进程来执行下载任务。进程启动后是由操作系统控制执行的。具体是并发执行还是并行执行这个是根据操作系统来的如果系统是单核的就只能是并发。 如果系统是多核的可能是并行。
3、这里图片的下载列表用的是队列不是list。 2.1 多进程与多线程的区别
以上面的下载大量图片的场景为例
多进程会独享资源2个进程不能共享变量例如不能共享list所以实现共享资源的方式就要使用其他手段如使用队列Queue 、 内存数据库redis等等
多线程占用资源少2个线程是共享变量的。一般的网盘下载之类的应用使用的是多线程的技术。 2.2 多进程为啥要使用队列
多进程中使用队列时不能使用其他包的中的队列必需使用 多进程包中的队列
from multiprocessing import Process,Queue
多进程会独享资源2个进程不能共享变量例如不能共享list所以实现共享资源的方式就要使用其他手段。
进程1会占用一块单独的内存存放 变量list进程2也会占用一块单独的内存存放 变量list 每个进程都有一份自己的变量这样执行时list就会被执行两次。
队列可以被进程1与进程2 共享队列只会被遍历一次。 举个小例子
使用list作为变量存储数据。
from multiprocessing import Processdef worker1(data:list):print(worker1 开始工作)while data:print(fworker1 取到列表中元素{data.pop()})def worker2(data:list):print(worker2 开始工作)while data:print(fworker2 取到列表中元素{data.pop()})if __name__ __main__:list [x for x in range(10)]p1 Process(targetworker1,args(list,))p2 Process(targetworker2, args(list,))p1.start()p2.start()print(主程序运行完毕)
打印结果
worker1 开始工作
worker1 取到列表中元素9
worker1 取到列表中元素8
worker1 取到列表中元素7
worker1 取到列表中元素6
worker1 取到列表中元素5
worker1 取到列表中元素4
worker1 取到列表中元素3
worker1 取到列表中元素2
worker1 取到列表中元素1
worker1 取到列表中元素0
主程序运行完毕
worker2 开始工作
worker2 取到列表中元素9
worker2 取到列表中元素8
worker2 取到列表中元素7
worker2 取到列表中元素6
worker2 取到列表中元素5
worker2 取到列表中元素4
worker2 取到列表中元素3
worker2 取到列表中元素2
worker2 取到列表中元素1
worker2 取到列表中元素0使用队列Queue作为变量存储数据。
import time
from multiprocessing import Process,Queuedef worker1(data:Queue):print(worker1 开始工作)while not data.empty():print(fworker1 取到列表中元素{data.get()})time.sleep(1)def worker2(data:Queue):print(worker2 开始工作)while not data.empty():print(fworker2 取到列表中元素{data.get()})time.sleep(1)if __name__ __main__:q Queue()for x in range(10):q.put(x)p1 Process(targetworker1,args(q,))p2 Process(targetworker2, args(q,))p1.start()p2.start()print(主程序运行完毕)打印结果
worker1 开始工作
worker1 取到列表中元素0
主程序运行完毕
worker2 开始工作
worker2 取到列表中元素1
worker1 取到列表中元素2
worker2 取到列表中元素3
worker1 取到列表中元素4
worker2 取到列表中元素5
worker1 取到列表中元素6
worker2 取到列表中元素7
worker1 取到列表中元素8
worker2 取到列表中元素9
2.3 控制进程运行顺序
2.3.1 join
join 以后的代码要等当前进程运行完才开始执行
import time
from multiprocessing import Process,Queuedef worker1(data:Queue):print(worker1 开始工作)while not data.empty():print(fworker1 取到列表中元素{data.get()})time.sleep(1)def worker2(data:Queue):print(worker2 开始工作)while not data.empty():print(fworker2 取到列表中元素{data.get()})time.sleep(1)if __name__ __main__:q Queue()for x in range(10):q.put(x)p1 Process(targetworker1,args(q,))p2 Process(targetworker2, args(q,))p1.start()p2.start()print(主程序运行完毕)打印结果
worker1 开始工作
worker1 取到列表中元素0
主程序运行完毕
worker2 开始工作
worker2 取到列表中元素1
worker1 取到列表中元素2
worker2 取到列表中元素3
worker1 取到列表中元素4
worker2 取到列表中元素5
worker1 取到列表中元素6
worker2 取到列表中元素7
worker1 取到列表中元素8
worker2 取到列表中元素9
我们一共运行了三个进程一个主进程一个worker1 进程一个 worker2 进程。
三个进程运行属于并发运行。我们想要控制进程的运行顺序可以使用join() 函数。 运行p1 进程后调用join方法。
则 p1.join()后面的代码 只能等到p1进程运行完成后才开始执行。 子进程运行完成后再运行主进程。
p1.join()
p2.join() 2.3.1 daemon 守护进程
在主进程运行完成后守护进程会被强制关闭。
# -*- coding:utf-8 -*-
# Author: 喵酱
# time: 2023 - 02 -25
# File: list1.py
import os
import time
from multiprocessing import Process, Queuedef worker1(data: Queue):print(fworker1 开始工作,进程id为{os.getpid()})while not data.empty():print(fworker1 取到列表中元素{data.get()})time.sleep(1)def worker2(data: Queue):print(fworker2 开始工作,进程id为{os.getpid()})while not data.empty():print(fworker2 取到列表中元素{data.get()})time.sleep(1)if __name__ __main__:q Queue()for x in range(10):q.put(x)p1 Process(targetworker1, args(q,))p2 Process(targetworker2, args(q,))p1.daemon Truep2.daemon Trueprint(f主进程的id: {os.getpid()})p2.start()p1.start()print(主程序运行完毕)
主进程的id: 36116
worker2 开始工作,进程id为36117
主程序运行完毕
worker2 取到列表中元素0
注意
1、设置守护进程 p1.daemon True
默认为False, 为True时将这个进程设置为守护进程
2、只有未开始执行的进程才能被设置成守护进程。已经开始执行的进程已经调用start方法的进程正在执行的进程是不可以被设置成守护进程。
先设置
p1.daemon True
再执行
p1.start() 应用场景
主进程结束后需要同时结束其他的子进程。 2.4 进程id
我们通过os模块来获取进程id
import os
import time
from multiprocessing import Process,Queuedef worker1(data:Queue):print(fworker1 开始工作,进程id为{os.getpid()})while not data.empty():print(fworker1 取到列表中元素{data.get()})time.sleep(1)def worker2(data:Queue):print(fworker2 开始工作,进程id为{os.getpid()})while not data.empty():print(fworker2 取到列表中元素{data.get()})time.sleep(1)if __name__ __main__:q Queue()for x in range(10):q.put(x)p1 Process(targetworker1,args(q,))p2 Process(targetworker2, args(q,))p1.start()p2.start()print(f主进程的id: {os.getpid()})print(主程序运行完毕)worker1 开始工作,进程id为25249
主进程的id: 25248
主程序运行完毕
worker1 取到列表中元素0
worker2 开始工作,进程id为25250
worker2 取到列表中元素1
worker1 取到列表中元素2
worker2 取到列表中元素3
worker1 取到列表中元素4
worker2 取到列表中元素5
worker1 取到列表中元素6
worker2 取到列表中元素7
worker1 取到列表中元素8
worker2 取到列表中元素9 2.5 进程 存活状态is_alive()
p1.is_alive() 为True p1进程当前为存活状态。 2.5 实现自定义多进程类
实现自定义多进程类的模版
from multiprocessing import Processclass MyProcess(Process):def __init__(self):super().__init__()def run(self) - None:print(运行)if __name__ __main__:p1 MyProcess()p2 MyProcess()p1.start() # start() 会调用MyProcess 中的run方法p2.start()1、继承Process
2、重写run方法。start 调用的run方法 三、多线程 threading
java 程序是多线程。jmeter 与 tomcat 是java编写的是多线程。
nginx 是C语言编写的。nginx的工作模式是多进程的而不是多线程的。 什么场景适用于多线程
--------间歇性占用CPU的场景适合多线程IO密集型的
比如网络io、磁盘读写的时候是不需要消耗cpu的此时就可以把cpu让出来给其他线程来支持多线程。
举个小例子
在日常生活中一个人可以同时熬3锅粥。每锅粥只需要小部分时间的搅拌其他时间就等待。
工作人员可以在第一锅粥的等待时间去给第二锅粥做搅拌合理利用时间来支持3个线程。
------CPU密集型的不适合多线程。
某个场景需要一直消耗cpu把cpu让出去再拿回来反而会影响我们的效率。
就比如一个人 做2道数学题。单线程就是先做完一道再做下一道。
多线程就是第一道数据题先做一分钟然后下一分钟再去做另一道。然后再回来做第一道数学题。 这种一直需要使用cpu场景,不适合多线程。 import threading
import timedef music(name: str):print(f正在播放音乐:{name})time.sleep(1)def play_game(name: str):print(f正在{name}游戏)time.sleep(2)if __name__ __main__:# 创建线程1t1 threading.Thread(targetmusic, args(无地自容,), name线程1)# 创建线程2t2 threading.Thread(targetplay_game, args(英雄联盟,), name线程2)# 开始线程t1.start()t2.start()# 阻塞主程序t1.join()t2.join()print(所有线程都结束了)打印结果
正在播放音乐:无地自容
正在英雄联盟游戏
所有线程都结束了
注意
1、可以设置每个线程的名字name
2、传参是元组当只有一个参数时后面也需要加逗号
3、join() 可以阻塞主程序
3.1 线程锁
多线程时尽量不要使用全局变量。
操作内存或者文件的代码要上锁。同一时间只允许一个线程进行访问。
注意
1、锁住的代码越少越好。
举例子
多个线程操作同一个内存 import threading
n 500000def work():global nfor i in range(100000):n - 1
if __name__ __main__:t1 threading.Thread(targetwork,name 线程1)t2 threading.Thread(targetwork, name线程2)t3 threading.Thread(targetwork, name线程3)t1.start()t2.start()t3.start()t1.join()t2.join()t3.join()print(n)
打印结果
291376
分析
n500000
三个线程每个线程操作n- 1000000 ,最后 n的值应该为 200000。
但是为啥最后值不对呢
因为在某一个瞬间多个线程对n 操作时造成数据错乱。
比如当n 为 100 时 线程1 与线程2 在这一瞬间同时读取n 则读到的n都是 100 再进行-1
线程1 与线程2 操作完后n 的值 为 99。 我们期望的结果是 98。 线程1 与线程2 使n 减少2 解决办法加锁 import threading
n 500000
lock threading.Lock()def work():global nfor i in range(100000):# 在对内存进行操作之前加锁lock.acquire()n - 1# 在对内存进行操作之后释放锁lock.release()
if __name__ __main__:t1 threading.Thread(targetwork,name 线程1)t2 threading.Thread(targetwork, name线程2)t3 threading.Thread(targetwork, name线程3)t1.start()t2.start()t3.start()t1.join()t2.join()t3.join()print(n)
打印结果
200000 # 在对内存进行操作之前加锁 lock.acquire() n - 1 # 在对内存进行操作之后释放锁 lock.release() 也可以用with lock: 这种写法来加锁 import threading
n 500000
lock threading.Lock()def work():global nfor i in range(100000):with lock:n - 1
if __name__ __main__:t1 threading.Thread(targetwork,name 线程1)t2 threading.Thread(targetwork, name线程2)t3 threading.Thread(targetwork, name线程3)t1.start()t2.start()t3.start()t1.join()t2.join()t3.join()print(n) 贴个链接
python 多线程就这么简单 - 虫师 - 博客园
虫师写的很通俗易懂且经典。
值得注意的是
threads []
t1 threading.Thread(targetmusic,args(u爱情买卖,))
threads.append(t1)
t2 threading.Thread(targetmove,args(u阿凡达,))
threads.append(t2)
这里添加线程的时候args内即使传一个参数后面也需要跟一个逗号
args(u爱情买卖,)
不然会报错。args里面传的是一个元组。
四、线程池、进程池
4.1 线程池 from multiprocessing.pool import ThreadPool
import queuedef download(q: queue.Queue):while not q.empty():print(f从队列中取出了{q.get()}元素)# 在队列中本次的任务执行完成q.task_done()if __name__ __main__:# 创建队列q queue.Queue()for i in range(10):q.put(i)# 创建线程池# 线程池中有2个线程pool ThreadPool(2)# 异步的调用指定函数pool.apply_async(download, (q,))# 等待所有的任务做完再做下一步q.join()print(finished)1、线程池引入 队列引入
from multiprocessing.pool import ThreadPool
import queue
2、多个线程异步执行效率高 # 异步的调用指定函数pool.apply_async(download, (q,))3、队列执行完毕的通知
q.task_done()
队列q,每执行完一次任务。就-1 q.join(),
当q中所有的任务都被执行完成时才会执行下一行代码。 4.2 进程池
导包
from multiprocessing import Pool
4.2.1 pool.map( func, iterable) import time
from multiprocessing import Pooldef square(x):print(fx 的平方是 {x * x})time.sleep(1)return x * xif __name__ __main__:# 开始运行时间start_time time.time()# 设置进程池中有2个进程pool Pool(2)result pool.map(square, [1, 2, 3, 4, 5, 6, 7])print(fresult is {result})# 结束进程池pool.close()end_time time.time()print(f总共用了{(end_time - start_time):.2f})打印结果
x 的平方是 1
x 的平方是 4
x 的平方是 9
x 的平方是 16
x 的平方是 25
x 的平方是 36
x 的平方是 49
result is [1, 4, 9, 16, 25, 36, 49]
总共用了4.05
注意
1、pool.map(func, iterable)
func 函数名称
iterable一个可迭代对象
可迭代对象[1,2,3,4,5,6,7] 里的每一个元素分别执行square 函数。本次启动了2个进程来完成这些
pool.map(square, [1, 2, 3, 4, 5, 6, 7])
这里我们没有调用join 函数因为map函数可以阻塞主程序。当执行map时可迭代对象中没有执行完所有的任务时不会执行下一步主程序代码所以不需要我们再加join方法。 2、时间保留了小数点后两位
end_time - start_time):.2f
3、 查看map源码 4.2.2 pool.map_async( func, iterable)
# -*- coding:utf-8 -*-
# Author: 喵酱
# time: 2023 - 02 -26
# File: jinchengchi1.pyimport time
from multiprocessing import Pooldef square(x):print(fx 的平方是 {x * x})time.sleep(1)return x * xif __name__ __main__:# 设置进程池中有2个进程pool Pool(2)result pool.map_async(square, [1, 2, 3, 4, 5, 6, 7]).get() # 等价于 pool.mapprint(result)# 结束进程池pool.close()执行结果
x 的平方是 1
x 的平方是 4
x 的平方是 9
x 的平方是 16
x 的平方是 25
x 的平方是 36
x 的平方是 49
[1, 4, 9, 16, 25, 36, 49]pool.map 与 pool.async 有啥区别
查看map源码。 pool.map 比 pool.async 多调用了一个get
感觉好像多了一个get 函数取执行结果之外没啥区别。。
4.2.3 pool.apply(self, func, args(), kwds{})
源码 注意传参第一个为函数第二个是 参数不是可迭代对象。
举例 import time
from multiprocessing import Pooldef num_add(x,y):print(f{x} {y} {xy})time.sleep(1)return x yif __name__ __main__:# 设置进程池中有2个进程pool Pool(2)result pool.apply(num_add,(2,3),)print(result) 打印结果
2 3 5
5 apply 与 map 的区别
apply 调用函数传递任意参数
map 把一个可迭代对象映射到函数。每个元素都会分别执行一次函数 传参
当函数里有关键参数时传参需要加一个字典。
举例
from multiprocessing import Pooldef num_add(x,y,z 0):return x y zif __name__ __main__:# 设置进程池中有2个进程pool Pool(2)result pool.apply(num_add,(2,3),{z:4})print(result)给函数中的z赋值时可以加一个字典{z:4} 4.2.4 pool.apply_async(self, func, args(), kwds{}) apply_async 与 apply 使用方法是一致的
表现形式上apply_async 比 apply 多了一个get()
但是本质上 apply 会阻塞主程序apply_async 不会阻塞主程序。
举例 import time
from multiprocessing import Pooldef num_add(x,y):print(f{x} {y} {xy})time.sleep(1)return x yif __name__ __main__:# 设置进程池中有2个进程pool Pool(2)result pool.apply_async(num_add,(2,3),)print(result)print(运行结束)打印结果
multiprocessing.pool.ApplyResult object at 0x7feb20127550
运行结束
2 3 5 分析
由于 子进程比较消耗时间所以主程序先执行完子进程后执行完。
子进程没有阻塞主程序的进行。 result pool.apply_async(num_add,(2,3),)print(result)
打印结果
multiprocessing.pool.ApplyResult object at 0x7fe018181790 想要获取 result的值需要加get() result pool.apply_async(num_add,(2,3),).get()print(result)
打印结果
5
当 apply_async 加了get() 之后就等价于 apply 了。
决定 子进程是否会阻塞主程序的因素是get
有get就会阻塞主程序。apply 里有get函数。 五、协程
六、进程的相关知识
6.1 进程的各种状态 就绪状态Running)
进程已经准备好已分配到所需资源只要分配到CPU就能够立即运行。
运行态和就绪态之间的转换是由进程调度程序引起的进程调度程序是操作系统的一部分。
就绪状态不消耗cpu
运行状态Running)
进程处于就绪状态被调度后进程进入执行状态
可中断睡眠状态
正在运行的进程由于某些事件而暂时无法运行进程受到阻塞。在条件满足就会被唤醒也可以提前被信号打断唤醒进入就绪状态等待系统调用
一般都是等待事务这个过程很长不知道啥时候返回结果。比如python中的input
不可中断睡眠状态磁盘休眠状态
除了不会因为接收到信号而被唤醒运行之外他与可中断状态相同。
等待资源过程很快会返回结果毫秒级别不用打断。在满足请求时进入就绪状态等待系统调用。
在这个状态的进程通常会等待IO的结束。
比如
cpu是在内存里运行的数据缺失会去磁盘里取读取磁盘等待数据磁盘从数据返回这个过程是就是不可中断。
这个过程很快。
终止状态/僵尸状态ZOMBIE
该进程已经结束了但是父进程还没有使用wait()系统调用。因为父进程不能读取到子进程退出的返回代码所以就会产生僵死进程。为了父进程能够获知它的消息子进程的进程描述符仍然被保留一但父进程调用wait()进程描述符就会被释放。该进程无法再被执行
停止状态
进程停止执行进程不能投入运行。通常这种状态发生在接受到SIGSTOP、SIGTSTP、SIGTTIN、SIGOUT等信号停止信号的时候正常停止。此外在调试期间接受到的任何信号都会使进程进入这种状态。 在linux中可以使用top命令查看s列为每个进程的状态。 线程的就绪状态与运行状态都是RRUNNING)状态。我们无法从R上区分当前进程到底是就绪还是正在运行。 进程与线程
进程之间相互独立但同一进程下的各个线程之间共享程序的内存空间(包括代码段、数据集、堆等)及一些进程级的资源(如打开文件和信号)某进程内的线程在其它进程不可见 6.2 上下文切换
在每个任务运行前CPU 都需要知道任务从哪里加载、又从哪里开始运行也就是说需要系统事先帮它设置好 CPU 寄存器和程序计数器
CPU 寄存器是 CPU 内置的容量小、但速度极快的内存。而程序计数器则是用来存储CPU 正在执行的指令位置、或者即将执行的下一条指令位置。它们都是 CPU 在运行任何任务前必须的依赖环境因此也被叫做 CPU 上下文
CPU 上下文切换就是先把前一个任务的 CPU 上下文也就是 CPU 寄存器和程序计数器保存起来然后加载新任务的上下文到这些寄存器和程序计数器最后再跳转到程序计数器所指的新位置运行新任务。
3种上下文切换情况
根据任务的不同CPU 的上下文切换就可以分为几个不同的场景也就是进程上下文切换、线程上下文切换以及中断上下文切换。 进程内核空间/用户空间切换导致CPU上下文切换
Linux 按照特权等级把进程的运行空间分为内核空间和用户空间CPU 特权等级的 Ring 0 和 Ring 3。进程既可以在用户空间运行又可以在内核空间中运行。
进程在用户空间运行时被称为进程的用户态而陷入内核空间的时候被称为进程的内核态。
从用户态到内核态的转变需要通过系统调用来完成。
比如当我们查看文件内容时就需要多次系统调用来完成首先调用 open() 打开文件然后调用 read() 读取文件内容并调用 write() 将内容写到标准输出最后再调用 close() 关闭文件。
内核空间Ring 0具有最高权限可以直接访问所有资源
用户空间Ring 3只能访问受限资源不能直接访问内存等硬件设备必须通过系统调用陷入到内核中才能访问这些特权资源。
系统调用进程内核空间/用户空间切换的过程发生 CPU 上下文切换
CPU 寄存器里原来用户态的指令位置需要先保存起来。
接着为了执行内核态代码CPU 寄存器需要更新为内核态指令的新位置。
最后才是跳转到内核态运行内核任务 。
而系统调用结束后CPU 寄存器需要恢复原来保存的用户态然后再切换到用户空间继续运行进程。
所以一次系统调用的过程其实是发生了两次 CPU 上下文切换。
系统调用过程中并不会涉及到虚拟内存等进程用户态的资源也不会切换进程。这跟我们通常所说的进程上下文切换是不一样的
进程上下文切换是指从一个进程切换到另一个进程运行。
而系统调用过程中一直是同一个进程在运行。 进程上下文切换
进程是由内核来管理和调度的进程的切换只能发生在内核态。
所以进程的上下文不仅包括了虚拟内存、栈、全局变量等用户空间的资源还包括了内核堆栈、寄存器等内核空间的状态。
因此进程的上下文切换就比系统调用时多了一步
在保存当前进程的内核状态和 CPU 寄存器之前需要先把该进程的虚拟内存、栈等保存下来
而加载了下一进程的内核态后还需要刷新进程的虚拟内存和用户栈。
如下图所示保存上下文和恢复上下文的过程并不是“免费”的需要内核在 CPU 上运行才能完成。 每次上下文切换都需要几十纳秒到数微秒的 CPU 时间。
这个时间还是相当可观的特别是在进程上下文切换次数较多的情况下很容易导致 CPU 将大量时间耗费在寄存器、内核栈以及虚拟内存等资源的保存和恢复上进而大大缩短了真正运行进程的时间。
大量的上下文切换会消耗我们的cpu导致平均负载升高。
进程切换时才需要切换上下文换句话说只有在进程调度的时候才需要切换上下文。
Linux 为每个 CPU 都维护了一个就绪队列将活跃进程即正在运行和正在等待CPU 的进程按照优先级和等待 CPU 的时间排序然后选择最需要 CPU 的进程也就是优先级最高和等待 CPU 时间最长的进程来运行。 进程在什么时候才会被调度到cpu上运行
场景一
就是一个进程执行完终止了它之前使用的 CPU 会释放出来这个时候再从就绪队列里拿一个新的进程过来运行。
场景二
为了保证所有进程可以得到公平调度CPU 时间被划分为一段段的时间片这些时间片再被轮流分配给各个进程。
这样当某个进程的时间片耗尽了就会被系统挂起切换到其它正在等待 CPU 的进程运行。
场景三
进程在系统资源不足比如内存不足时要等到资源满足后才可以运行这个时候进程也会被挂起并由系统调度其他进程运行。
场景四
当进程通过睡眠函数 sleep 这样的方法将自己主动挂起时自然也会重新调度。
场景五
当有优先级更高的进程运行时为了保证高优先级进程的运行当前进程会被挂起由高优先级进程来运行。
场景六
发生硬件中断时CPU 上的进程会被中断挂起转而执行内核中的中断服务程序。 线程上下文切换
线程与进程最大的区别在于线程是调度的基本单位而进程则是资源拥有的基本单位。
所谓内核中的任务调度实际上的调度对象是线程而进程只是给线程提供了虚拟内存、全局变量等资源。
可以这么理解线程和进程
当进程只有一个线程时可以认为进程就等于线程。
当进程拥有多个线程时这些线程会共享相同的虚拟内存和全局变量等资源。这些资源在上下文切换时是不需要修改的。
另外线程也有自己的私有数据比如栈和寄存器等这些在上下文切换时也是需要保存的。 线程的上下文切换其实就可以分为两种情况
第一种前后两个线程属于不同进程。此时因为资源不共享所以切换过程就跟进程上下文切换是一样。
第二种前后两个线程属于同一个进程。此时因为虚拟内存是共享的所以在切换时虚拟内存这些资源就保持不动只需要切换线程的私有数据、寄存器等不共享的数据
同进程内的线程切换要比多进程间的切换消耗更少的资源而这也正是多线程代替多进程的一个优势 中断上下文切换
为了快速响应硬件的事件中断处理会打断进程的正常调度和执行转而调用中断处理程序响应设备事件。而在打断其他进程时就需要将进程当前的状态保存下来这样在中断结束后进程仍然可以从原来的状态恢复运行。
跟进程上下文不同中断上下文切换并不涉及到进程的用户态。所以即便中断过程打断了一个正处在用户态的进程也不需要保存和恢复这个进程的虚拟内存、全局变量等用户态资源。
中断上下文其实只包括内核态中断服务程序执行所必需的状态包括 CPU 寄存器、内核堆栈、硬件中断参数等。对同一个 CPU 来说中断处理比进程拥有更高的优先级所以中断上下文切换并不会与进程上下文切换同时发生。同样道理由于中断会打断正常进程的调度和执行所以大部分中断处理程序都短小精悍以便尽可能快的执行结束。另外跟进程上下文切换一样中断上下文切换也需要消耗 CPU切换次数过多也会耗费大量的 CPU甚至严重降低系统的整体性能。所以当你发现中断次数过多时就需要注意去排查它是否会给你的系统带来严重的性能问题 文章转载自： http://www.morning.mjbkp.cn.gov.cn.mjbkp.cn http://www.morning.hgsmz.cn.gov.cn.hgsmz.cn http://www.morning.hfnbr.cn.gov.cn.hfnbr.cn http://www.morning.ccffs.cn.gov.cn.ccffs.cn http://www.morning.nxwk.cn.gov.cn.nxwk.cn http://www.morning.ptwrz.cn.gov.cn.ptwrz.cn http://www.morning.xyrw.cn.gov.cn.xyrw.cn http://www.morning.xxrwp.cn.gov.cn.xxrwp.cn http://www.morning.rlhgx.cn.gov.cn.rlhgx.cn http://www.morning.fqyqm.cn.gov.cn.fqyqm.cn http://www.morning.jfbrt.cn.gov.cn.jfbrt.cn http://www.morning.srrrz.cn.gov.cn.srrrz.cn http://www.morning.seoqun.com.gov.cn.seoqun.com http://www.morning.rtmqy.cn.gov.cn.rtmqy.cn http://www.morning.szoptic.com.gov.cn.szoptic.com http://www.morning.xsbhg.cn.gov.cn.xsbhg.cn http://www.morning.ylqrc.cn.gov.cn.ylqrc.cn http://www.morning.ljfjm.cn.gov.cn.ljfjm.cn http://www.morning.lxlfr.cn.gov.cn.lxlfr.cn http://www.morning.srgnd.cn.gov.cn.srgnd.cn http://www.morning.lzdbb.cn.gov.cn.lzdbb.cn http://www.morning.ybqlb.cn.gov.cn.ybqlb.cn http://www.morning.ztcwp.cn.gov.cn.ztcwp.cn http://www.morning.mhsmj.cn.gov.cn.mhsmj.cn http://www.morning.dhbyj.cn.gov.cn.dhbyj.cn http://www.morning.sfyqs.cn.gov.cn.sfyqs.cn http://www.morning.ffdyy.cn.gov.cn.ffdyy.cn http://www.morning.dbjyb.cn.gov.cn.dbjyb.cn http://www.morning.tjpmf.cn.gov.cn.tjpmf.cn http://www.morning.kfqzd.cn.gov.cn.kfqzd.cn http://www.morning.tnwgc.cn.gov.cn.tnwgc.cn http://www.morning.nptls.cn.gov.cn.nptls.cn http://www.morning.tzmjc.cn.gov.cn.tzmjc.cn http://www.morning.nsrtvu.com.gov.cn.nsrtvu.com http://www.morning.gkmwx.cn.gov.cn.gkmwx.cn http://www.morning.sftrt.cn.gov.cn.sftrt.cn http://www.morning.jbblf.cn.gov.cn.jbblf.cn http://www.morning.bmts.cn.gov.cn.bmts.cn http://www.morning.jthjr.cn.gov.cn.jthjr.cn http://www.morning.wnrcj.cn.gov.cn.wnrcj.cn http://www.morning.krzrg.cn.gov.cn.krzrg.cn http://www.morning.rynqh.cn.gov.cn.rynqh.cn http://www.morning.ujianji.com.gov.cn.ujianji.com http://www.morning.tckxl.cn.gov.cn.tckxl.cn http://www.morning.xnnpy.cn.gov.cn.xnnpy.cn http://www.morning.kzpxc.cn.gov.cn.kzpxc.cn http://www.morning.rsnd.cn.gov.cn.rsnd.cn http://www.morning.rcjqgy.com.gov.cn.rcjqgy.com http://www.morning.jkfyt.cn.gov.cn.jkfyt.cn http://www.morning.iknty.cn.gov.cn.iknty.cn http://www.morning.rmyt.cn.gov.cn.rmyt.cn http://www.morning.hmmtx.cn.gov.cn.hmmtx.cn http://www.morning.lxctl.cn.gov.cn.lxctl.cn http://www.morning.qctsd.cn.gov.cn.qctsd.cn http://www.morning.jjxnp.cn.gov.cn.jjxnp.cn http://www.morning.zpdjh.cn.gov.cn.zpdjh.cn http://www.morning.tgfsr.cn.gov.cn.tgfsr.cn http://www.morning.pggkr.cn.gov.cn.pggkr.cn http://www.morning.mzpd.cn.gov.cn.mzpd.cn http://www.morning.jfsbs.cn.gov.cn.jfsbs.cn http://www.morning.hlnrj.cn.gov.cn.hlnrj.cn http://www.morning.bnkcl.cn.gov.cn.bnkcl.cn http://www.morning.rfdqr.cn.gov.cn.rfdqr.cn http://www.morning.nrqtk.cn.gov.cn.nrqtk.cn http://www.morning.gxhqt.cn.gov.cn.gxhqt.cn http://www.morning.gftnx.cn.gov.cn.gftnx.cn http://www.morning.dcccl.cn.gov.cn.dcccl.cn http://www.morning.lxkhx.cn.gov.cn.lxkhx.cn http://www.morning.sphft.cn.gov.cn.sphft.cn http://www.morning.wmdbn.cn.gov.cn.wmdbn.cn http://www.morning.rsjf.cn.gov.cn.rsjf.cn http://www.morning.clpdm.cn.gov.cn.clpdm.cn http://www.morning.pdmml.cn.gov.cn.pdmml.cn http://www.morning.gmyhq.cn.gov.cn.gmyhq.cn http://www.morning.nkkr.cn.gov.cn.nkkr.cn http://www.morning.mpyry.cn.gov.cn.mpyry.cn http://www.morning.jxcwn.cn.gov.cn.jxcwn.cn http://www.morning.xnkb.cn.gov.cn.xnkb.cn http://www.morning.qscsy.cn.gov.cn.qscsy.cn http://www.morning.hksxq.cn.gov.cn.hksxq.cn
