进程+线程+协程

2024-09-06 09:20
文章标签 线程 进程 协程

本文主要是介绍进程+线程+协程，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

进程+线程+协程

  • 1 进程
    • 1.1 无进程
    • 1.2 多进程
    • 1.3 p1.join()
    • 1.4 权重
    • 1.5 全局变量list

1 进程

1.1 无进程

不使用进程，task_01和task_02先后执行


import os
import time
from  multiprocessing import Processdef task_01():print("*"*8+' task_01 '+"*"*8)i = 0while True:time.sleep(0.5)print('task_01:  %d'%i)i += 1if i>10:breakdef task_02():print("*"*8+' task_02 '+"*"*8)i = 0while True:time.sleep(1)print('task_02:  %d'%i)i += 10if i>30:breakif __name__ == '__main__':print("*"*8+' 主程序开始 '+"*"*8)task_01()task_02()print("#" * 8 + ' 主程序结束 ' + "#" * 8)
‘’‘
## 运行结果
******** 主程序开始 ********
******** task_01 ********
task_01:  0
task_01:  1
task_01:  2
task_01:  3
task_01:  4
task_01:  5
task_01:  6
task_01:  7
task_01:  8
task_01:  9
task_01:  10
******** task_02 ********
task_02:  0
task_02:  10
task_02:  20
task_02:  30
######## 主程序结束 ########
Process finished with exit code 0
‘’‘

1.2 多进程

父程序和子程序各自执行，互不干扰。由于只有一个核，task_01和task_02交替执行。

import os
import time
from  multiprocessing import Processdef task_01():print("*"*8+' task_01 '+"*"*8)i = 0while True:time.sleep(0.5)print('task_01:  %d'%i)i += 1if i>10:breakdef task_02():print("*"*8+' task_02 '+"*"*8)i = 0while True:time.sleep(1)print('task_02:  %d'%i)i += 10if i>100:breakif __name__ == '__main__':print("*"*8+' 主程序开始 '+"*"*8)p1 = Process(target = task_01,name="任务1")  # 子程序实例化p2 = Process(target = task_02,name="任务2")p1.start()   # 开启子程序p2.start()print("#" * 8 + ' 主程序结束 ' + "#" * 8)## 运行结果
'''
******** 主程序开始 ********
######## 主程序结束 ########
******** task_01 ********
******** task_02 ********
task_01:  0
task_02:  0
task_01:  1
task_01:  2
task_02:  10
task_01:  3
task_01:  4
task_02:  20
task_01:  5
task_01:  6
task_02:  30
task_01:  7
task_01:  8
task_02:  40
task_01:  9
task_01:  10
task_02:  50
task_02:  60
task_02:  70
task_02:  80
task_02:  90
task_02:  100Process finished with exit code 0
'''

1.3 p1.join()

p1.join() 表示主进程要等子进程执行完再执行p1.join()后面的代码

# 
import os
import time
from  multiprocessing import Processdef task_01(name,s):print("*"*8+' task_01 '+"*"*8)i = 0while True:time.sleep(s)print(' %s:  task_01.id: %d, i:  %d'%(name,os.getpid(),i))i += 1if i>40:breakdef task_02(name,s):print("*"*8+' task_02 '+"*"*8)j = 0while True:time.sleep(s)print(' %s:  task_02.id: %d, j:  %d'%(name,os.getpid(),j))j += 10if j>300:breakif __name__ == '__main__':print("*"*8+' 主程序开始 '+"*"*8)p1 = Process(target = task_01,name="任务1",args=("A",0.5))  #  给task_01传递参数p2 = Process(target = task_02,name="任务2",args=("B",1))count = 0p1.start()   # 开启子程序p2.start()print('p1.name: ',p1.name)print('p2.name: ',p2.name)## 通过主程序控制子程序count = 0while True:time.sleep(0.3)count += 5print('count: ', count)if count== 50:p1.terminate()p2.terminate()breakprint("#" * 8 + ' 主程序结束 ' + "#" * 8)
‘’‘
******** 主程序开始 ********
p1.name:  任务1
p2.name:  任务2
******** task_01 ********
******** task_02 ********
count:  5
count:  10A:  task_01.id: 3603, i:  0
count:  15A:  task_01.id: 3603, i:  1B:  task_02.id: 3604, j:  0
count:  20
count:  25A:  task_01.id: 3603, i:  2
count:  30
count:  35B:  task_02.id: 3604, j:  10A:  task_01.id: 3603, i:  3
count:  40A:  task_01.id: 3603, i:  4
count:  45
count:  50
######## 主程序结束 ########Process finished with exit code 0
‘’‘

1.4 权重

进程之间不共享权重


import os
import time
from  multiprocessing import Process
N = 1
def task_01(name,s):print("*"*8+' task_01 '+"*"*8)global Nwhile True:time.sleep(s)print(' %s:  task_01.id: %d, N:  %d'%(name,os.getpid(),N))N += 1if N>20:breakdef task_02(name,s):print("*"*8+' task_02 '+"*"*8)global Nwhile True:time.sleep(s)print(' %s:  task_02.id: %d, N:  %d'%(name,os.getpid(),N))N += 100if N>1000:breakif __name__ == '__main__':print("*"*8+' 主程序开始 '+"*"*8)p1 = Process(target = task_01,name="任务1",args=("A",0.5))  #  给task_01传递参数p2 = Process(target = task_02,name="任务2",args=("B",1))N = 100p1.start()   # 开启子程序p2.start()print('p1.name: ',p1.name)print('p2.name: ',p2.name)print("#" * 8 + ' 主程序结束 ' + "#" * 8)
‘’‘    
******** 主程序开始 ********
p1.name:  任务1
p2.name:  任务2
######## 主程序结束 ########
******** task_02 ********
******** task_01 ********A:  task_01.id: 3710, N:  1B:  task_02.id: 3711, N:  1A:  task_01.id: 3710, N:  2A:  task_01.id: 3710, N:  3B:  task_02.id: 3711, N:  101A:  task_01.id: 3710, N:  4A:  task_01.id: 3710, N:  5B:  task_02.id: 3711, N:  201A:  task_01.id: 3710, N:  6A:  task_01.id: 3710, N:  7B:  task_02.id: 3711, N:  301A:  task_01.id: 3710, N:  8A:  task_01.id: 3710, N:  9B:  task_02.id: 3711, N:  401A:  task_01.id: 3710, N:  10A:  task_01.id: 3710, N:  11B:  task_02.id: 3711, N:  501A:  task_01.id: 3710, N:  12A:  task_01.id: 3710, N:  13B:  task_02.id: 3711, N:  601A:  task_01.id: 3710, N:  14A:  task_01.id: 3710, N:  15B:  task_02.id: 3711, N:  701A:  task_01.id: 3710, N:  16A:  task_01.id: 3710, N:  17B:  task_02.id: 3711, N:  801A:  task_01.id: 3710, N:  18A:  task_01.id: 3710, N:  19B:  task_02.id: 3711, N:  901A:  task_01.id: 3710, N:  20Process finished with exit code 0
‘’‘

1.5 全局变量list

进程之间不共享全局变量list

# 
import os
import time
import random
from  multiprocessing import Process
N = []
def task_01(name,s):print("*"*8+' task_01 '+"*"*8)global Nwhile True:time.sleep(s)print(' {}:  task_01.id: {}, N1:  {}'.format(name,os.getpid(),N))N.append(-round(random.random(),1))if len(N)>9:breakdef task_02(name,s):print("*"*8+' task_02 '+"*"*8)global Nwhile True:time.sleep(s)print(' {}:  task_02.id: {}, N2:  {}'.format(name,os.getpid(),N))N.append(round(random.random())*100)if len(N)>8:breakif __name__ == '__main__':print("*"*8+' 主程序开始 '+"*"*8)p1 = Process(target = task_01,name="任务1",args=("A",0.5))  #  给task_01传递参数p2 = Process(target = task_02,name="任务2",args=("B",1))N = 100p1.start()   # 开启子程序p2.start()print('p1.name: ',p1.name)print('p2.name: ',p2.name)print("#" * 8 + ' 主程序结束 ' + "#" * 8)time.sleep(10)print('NNNNNN: ', N)
‘’‘
******** 主程序开始 ********
p1.name:  任务1
p2.name:  任务2
######## 主程序结束 ########
******** task_01 **************** task_02 ********A:  task_01.id: 3819, N1:  []B:  task_02.id: 3820, N2:  []A:  task_01.id: 3819, N1:  [-0.8]A:  task_01.id: 3819, N1:  [-0.8, -0.7]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8] B:  task_02.id: 3820, N2:  [0]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3]B:  task_02.id: 3820, N2:  [0, 0]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3, -0.3]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3, -0.3, -0.5]B:  task_02.id: 3820, N2:  [0, 0, 100]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3, -0.3, -0.5, -0.3]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3, -0.3, -0.5, -0.3, -0.9]B:  task_02.id: 3820, N2:  [0, 0, 100, 100]A:  task_01.id: 3819, N1:  [-0.8, -0.7, -0.8, -0.3, -0.3, -0.5, -0.3, -0.9, -0.2]B:  task_02.id: 3820, N2:  [0, 0, 100, 100, 100]B:  task_02.id: 3820, N2:  [0, 0, 100, 100, 100, 100]B:  task_02.id: 3820, N2:  [0, 0, 100, 100, 100, 100, 0]B:  task_02.id: 3820, N2:  [0, 0, 100, 100, 100, 100, 0, 0]
NNNNNN:  100Process finished with exit code 0
‘’‘

这篇关于进程+线程+协程的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1141621。

相关文章

Linux进程CPU绑定优化与实践过程

Linux进程CPU绑定优化与实践过程

《Linux进程CPU绑定优化与实践过程》Linux支持进程绑定至特定CPU核心,通过sched_setaffinity系统调用和taskset工具实现,优化缓存效率与上下文切换,提升多核计算性能,适... 目录1. 多核处理器及并行计算概念1.1 多核处理器架构概述1.2 并行计算的含义及重要性1.3 并
阅读更多...
Linux线程之线程的创建、属性、回收、退出、取消方式

Linux线程之线程的创建、属性、回收、退出、取消方式

《Linux线程之线程的创建、属性、回收、退出、取消方式》文章总结了线程管理核心知识：线程号唯一、创建方式、属性设置（如分离状态与栈大小）、回收机制（join/detach）、退出方法（返回/pthr... 目录1. 线程号2. 线程的创建3. 线程属性4. 线程的回收5. 线程的退出6. 线程的取消7.
阅读更多...
Linux下进程的CPU配置与线程绑定过程

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于
阅读更多...
Javaee多线程之进程和线程之间的区别和联系(最新整理)

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab
阅读更多...
SpringBoot线程池配置使用示例详解

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置（核心数、队列容量、拒绝策略等）及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略（Rejected
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...
Java进程异常故障定位及排查过程

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》：本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存
阅读更多...
Java 线程安全与 volatile与单例模式问题及解决方案

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因（调度随机、变量修改、非原子操作、内存可见性、指令重排序）及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操
阅读更多...
Windows的CMD窗口如何查看并杀死nginx进程

Windows的CMD窗口如何查看并杀死nginx进程

《Windows的CMD窗口如何查看并杀死nginx进程》：本文主要介绍Windows的CMD窗口如何查看并杀死nginx进程问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录Windows的CMD窗口查看并杀死nginx进程开启nginx查看nginx进程停止nginx服务
阅读更多...
Java中实现线程的创建和启动的方法

Java中实现线程的创建和启动的方法

《Java中实现线程的创建和启动的方法》在Java中,实现线程的创建和启动是两个不同但紧密相关的概念,理解为什么要启动线程（调用start()方法）而非直接调用run()方法,是掌握多线程编程的关键,... 目录1. 线程的生命周期2. start() vs run() 的本质区别3. 为什么必须通过 st
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2