热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Process的几个用法和守护进程

[TOC]Process的几个用法和守护进程一、Process的join用法话不多说,直接上代码二、Process的pid和ppid用法需要先导入os模块站在当前进程的角度:os.


目录




  • Process的几个用法和守护进程

    • 一、Process的 join用法

    • 二、Process的pid和ppid用法

      • 三、Process的name用法


    • 四、Process的is_alive的用法

    • 五、Process的terminate用法

    • 六、守护进程

    • 七、抢票小程序





Process的几个用法和守护进程

一、Process的 join用法


话不多说,直接上代码


join 用法一 ,单进程
from multiprocessing import Process
import time

def foo():
print('子进程 start')
time.sleep(2)
print('子进程 end')

if __name__ == '__main__':
p = Process(target=foo)
p.start()
# 核心需求就是想让子进程执行完,再执行主进程的print,time有弊端
# time.sleep(5)
p.join() # 在这阻塞住,主进程等待该子进程结束,然后再往下执行,(了解:内部会调用wait())
print('主进程')

# join用法二(并发)
from multiprocessing import Process
import time

def foo(x):
print('子进程 start')
time.sleep(x)
print('子进程 end')

if __name__ == '__main__':
p1 = Process(target=foo,args=(1,))
p2 = Process(target=foo,args=(2,))
p3 = Process(target=foo,args=(3,))
start = time.time()
p1.start()
p2.start()
p3.start() # 这几个相当于并发
# 核心需求就是想让子进程执行完,再执行主进程的print,time有弊端
# time.sleep(5)
p1.join() # 在这阻塞住,主进程等待该子进程结束,然后再往下执行,(了解:内部会调用wait())
p2.join()
p3.join()
# 总时长:按照最长的时间计算多一点
end = time.time()
print(end-start)
print('主进程')

# join用法三(串行)
from multiprocessing import Process
import time

def foo(x):
print('子进程 start')
time.sleep(x)
print('子进程 end')

if __name__ == '__main__':
p1 = Process(target=foo,args=(1,))
p2 = Process(target=foo,args=(2,))
p3 = Process(target=foo,args=(3,))
start = time.time()
p1.start()
p1.join() # 在这阻塞住,主进程等待该子进程结束,然后再往下执行,(了解:内部会调用wait())
p2.start()
p2.join()
p3.start() # 这几个相当于并行
p3.join()

# 核心需求就是想让子进程执行完,再执行主进程的print,time有弊端
# time.sleep(5)
# 总时长:按照最长的时间计算多一点
end = time.time()
print(end-start)
print('主进程')

# 优化join用法二
from multiprocessing import Process
import time

def foo(x):
print(f'子进程{x} start')
time.sleep(x)
print(f'子进程{x} end')

if __name__ == '__main__':
start = time.time()
p_list = []
for i in range(1,4):
p = Process(target=foo, args=(i,))
p.start()
p_list.append(p)
for p in p_list:
p.join()
end = time.time()
print(end-start)
print('主进程')

二、Process的pid和ppid用法


需要先导入os模块


站在当前进程的角度:os.getpid()>>>>获取当前进程的pid


? os.getppid()>>>>获取当前进程的父进程的pid


? 子进程对象.pid>>>>获取当前进程的子进程pid


具体看以下代码


from multiprocessing import Process,current_process
import time,os
def task():
print('子进程 start')
print('在子进程中查看自己的pid',current_process().pid) # 在子进程查看自己pid方法一
print('在子进程中查看自己的pid',os.getpid()) # 在子进程查看自己pid方法二
print('在子进程中查看父进程的pid',os.getppid())
time.sleep(2)
print('子进程 end')

if __name__ == '__main__':
p = Process(target=task)
p.start()
print('在主进程查看子进程的pid',p.pid) # 获取pid,一定要写在start()之后
print('主进程的pid',os.getpid())
print('主进程的父进程pid',os.getppid())
print('主进程')

在主进程查看子进程的pid 1928

主进程的pid 2900

主进程的父进程pid 1008

主进程

子进程 start

在子进程中查看自己的pid 1928

在子进程中查看自己的pid 1928

在子进程中查看父进程的pid 2900

子进程 end


三、Process的name用法


这是用来查看进程名的


from multiprocessing import Process,current_process
import time
def foo():
print('子进程 start')
print('>>>>',current_process().name) # 获取当前进程名
time.sleep(2)
print('子进程 end')

if __name__ == '__main__':
p = Process(target=foo)
p.start()
print(p.name)

Process-1

子进程 start


Process-1

子进程 end


四、Process的is_alive的用法


用来判断进程是否活着,结果是True或False


from multiprocessing import Process,current_process
import time
def foo():
print('子进程 start')
time.sleep(2)
print('子进程 end')

if __name__ == '__main__':
p = Process(target=foo)
p.start()
print(p.is_alive()) # 没运行完就活着 True
time.sleep(5)
print(p.is_alive()) # 代码运行完了就算死了 False
print('主进程')

True

子进程 start

子进程 end

False

主进程


五、Process的terminate用法


用来直接把进程终止(死掉)


from multiprocessing import Process,current_process
import time
def foo():
print('子进程 start')
time.sleep(50)
print('子进程 end')

if __name__ == '__main__':
p = Process(target=foo)
p.start()
p.terminate() # 给操作系统发了一个终止进程的请求
print(p.is_alive()) # 没运行完就活着 True
p.join() # 可以不等50秒,直接执行下面的
print(p.is_alive())

print('主进程')

True

False

主进程


六、守护进程


守护进程本质也是一个子进程,主进程的代码执行完毕,守护进程就直接结束


from multiprocessing import Process
import time
def foo():
print('守护进程 start')
time.sleep(10)
print('守护进程 end')

if __name__ == '__main__':
p = Process(target=foo)
p.daemon = True # 把这个子进程定义为了守护进程,只陪伴到打印主进程就结束
p.start()

print('主进程') # 这个执行完,主进程的代码就执行完毕,子进程就直接结束,

主进程


七、抢票小程序



from multiprocessing import Process
import json,time,os
def search():
time.sleep(1)
with open('db',mode='rt',encoding='utf-8') as fr:
res = json.load(fr)
print(f'还剩{res["count"]}张')

def get():
with open('db',mode='rt',encoding='utf-8') as fr:
res = json.load(fr)
time.sleep(1) # 模拟网络io
if res['count'] > 0:
res['count'] -= 1
with open('db',mode='wt',encoding='utf-8') as fw:
json.dump(res,fw)
time.sleep(1.5) # 模拟网络io
print(f'进程{os.getpid()}抢票成功')
else:
print('票已售罄!!!')

def task():
search()
get()

if __name__ == '__main__':
for i in range(15):
p = Process(target=task)
p.start()
p.join()

# 为了保证数据的安全,要牺牲掉效率

Process的几个用法和守护进程



推荐阅读
  • 本文介绍如何使用Python进行文本处理,包括分词和生成词云图。通过整合多个文本文件、去除停用词并生成词云图,展示文本数据的可视化分析方法。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 并发编程:深入理解设计原理与优化
    本文探讨了并发编程中的关键设计原则,特别是Java内存模型(JMM)的happens-before规则及其对多线程编程的影响。文章详细介绍了DCL双重检查锁定模式的问题及解决方案,并总结了不同处理器和内存模型之间的关系,旨在为程序员提供更深入的理解和最佳实践。 ... [详细]
  • 本文总结了2018年的关键成就,包括职业变动、购车、考取驾照等重要事件,并分享了读书、工作、家庭和朋友方面的感悟。同时,展望2019年,制定了健康、软实力提升和技术学习的具体目标。 ... [详细]
  • 1.如何在运行状态查看源代码?查看函数的源代码,我们通常会使用IDE来完成。比如在PyCharm中,你可以Ctrl+鼠标点击进入函数的源代码。那如果没有IDE呢?当我们想使用一个函 ... [详细]
  • 数据库内核开发入门 | 搭建研发环境的初步指南
    本课程将带你从零开始,逐步掌握数据库内核开发的基础知识和实践技能,重点介绍如何搭建OceanBase的开发环境。 ... [详细]
  • 如何在WPS Office for Mac中调整Word文档的文字排列方向
    本文将详细介绍如何使用最新版WPS Office for Mac调整Word文档中的文字排列方向。通过这些步骤,用户可以轻松更改文本的水平或垂直排列方式,以满足不同的排版需求。 ... [详细]
  • 本文详细解析了Python中的os和sys模块,介绍了它们的功能、常用方法及其在实际编程中的应用。 ... [详细]
  • 本文介绍如何使用 NSTimer 实现倒计时功能,详细讲解了初始化方法、参数配置以及具体实现步骤。通过示例代码展示如何创建和管理定时器,确保在指定时间间隔内执行特定任务。 ... [详细]
  • 本文介绍如何使用阿里云的fastjson库解析包含时间戳、IP地址和参数等信息的JSON格式文本,并进行数据处理和保存。 ... [详细]
  • andr ... [详细]
  • 本文介绍如何在Linux服务器之间使用SCP命令进行文件传输。SCP(Secure Copy Protocol)是一种基于SSH的安全文件传输协议,支持从远程机器复制文件到本地服务器或反之。示例包括从192.168.45.147复制tomcat目录到本地/home路径。 ... [详细]
  • 本文介绍了如何使用jQuery根据元素的类型(如复选框)和标签名(如段落)来获取DOM对象。这有助于更高效地操作网页中的特定元素。 ... [详细]
  • 本文详细介绍了如何通过命令行启动MySQL服务,包括打开命令提示符窗口、进入MySQL的bin目录、输入正确的连接命令以及注意事项。文中还提供了更多相关命令的资源链接。 ... [详细]
  • 本文介绍了在Windows环境下使用pydoc工具的方法,并详细解释了如何通过命令行和浏览器查看Python内置函数的文档。此外,还提供了关于raw_input和open函数的具体用法和功能说明。 ... [详细]
author-avatar
w3812127
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有