python基础-Process创建进程、join方法、实现ftp多进程

2024-08-31 22:38

本文主要是介绍python基础-Process创建进程、join方法、实现ftp多进程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

      • 进程概念
      • 获取进程id
      • 并行并发概念
      • Process类的介绍
      • Process类的其他方法
      • join方法
      • 利用多进程实现ftp套接字

进程概念

进程即正在执行的一个过程或者说一个任务。进程是对正在运行程序的一个抽象,而负责执行任务则是cpu
程序仅仅只是一堆代码而已,而进程指的是程序的运行过程。
进程的概念起源于操作系统,进程的创建,调度管理都归操作系统管

一 操作系统的作用:
1:隐藏丑陋复杂的硬件接口,提供良好的抽象接口
2:管理、调度进程,并且将多个进程对硬件的竞争变得有序

二 多道技术:
1.产生背景:针对单核,实现并发
ps:
现在的主机一般是多核,那么每个核都会利用多道技术
有4个cpu,运行于cpu1的某个程序遇到io阻塞,会等到io结束再重新调度,会被调度到4个
cpu中的任意一个,具体由操作系统调度算法决定。

2.空间上的复用:如内存中同时有多道程序
3.时间上的复用:复用一个cpu的时间片强调:遇到io切,占用cpu时间过长也切,核心在于切之前将进程的状态保存下来,这样才能保证下次切换回来时,能基于上次切走的位置继续运行

获取进程id

getpid是获得当前进程的进程号
getppid是获得当前进程的父进程的进程号

import time,os
print(os.getpid(),os.getppid())
time.sleep(1000)

输出如下:

1512 12032

这里写图片描述

并行、并发概念

一 并发:单个cpu+多道技术就可以实现并发,(并行也属于并发)
二 并行:同时运行,只有具备多个cpu才能实现并行
有四个核,六个任务,这样同一时间有四个任务被执行,假设分别被分配给了cpu1,cpu2,cpu3,cpu4,一旦任务1遇到I/O就被迫中断执行,此时任务5就拿到cpu1的时间片去执行,而一旦任务1的I/O结束了,操作系统会重新调用它(需知进程的调度、分配给哪个cpu运行,由操作系统说了算),可能被分配给四个cpu中的任意一个去执行

Process类的介绍

p.start() #只是在给操作系统发了一个信号,让操作系统去开进程(申请内存+拷贝父进程的地址空间)

方式一:


from multiprocessing import Process
import timedef task(name):print('%s is running' %name)time.sleep(2)if __name__ == '__main__': #在windows系统下,开子进程的代码必须写到这一行下面p=Process(target=task,args=('safly1',))p.start() #只是在给操作系统发了一个信号,让操作系统去开进程(申请内存+拷贝父进程的地址空间)p1 = Process(target=task, kwargs={"name":"safly2"})p1.start()print('主')

输出如下:

主
safly1 is running
safly2 is running

方式二:


from multiprocessing import Process
import timeclass Myprocess(Process):def __init__(self,name):super().__init__()self.name=namedef run(self):time.sleep(3)print('%s is running' % self.name)if __name__ == '__main__':  # 在windows系统下,开子进程的代码必须写到这一行下面p = Myprocess('safly')p.start()  # p.run()print('主')

输出如下:

主
safly is running

Process类的其他方法

from multiprocessing import Process
import time, random
def task():print('孙子运行了')time.sleep(3)def piao(name):print('%s is piaoing' % name)time.sleep(random.randint(1, 3))print('%s is done' % name)p=Process(target=task,)p.start()if __name__ == '__main__':p1=Process(target=piao,args=('alex',),name='xxxxxxxx')p1.start()print(p1.name)print(p1.pid)print(p1.is_alive())print('主')

输出如下:

E:\python\python_sdk\python.exe E:/python/py_pro/3_Process对象的属性与方法.py
xxxxxxxx
11816
True
主
alex is piaoing
alex is done
孙子运行了Process finished with exit code 0

join方法

join:主进程等,等待子进程结束

from multiprocessing import Process
import time,randomdef piao(name):print('%s is piaoing' %name)time.sleep(random.randint(1,3))print('%s is done' %name)if __name__ == '__main__':p1=Process(target=piao,args=('alex',))p2=Process(target=piao,args=('wxx',))p3=Process(target=piao,args=('yxx',))p1.start()p2.start()p3.start()p3.join()  # join(p)p1.join() #join(p)p2.join() #join(p)print('主')

输出如下:

alex is piaoing
wxx is piaoing
yxx is piaoing
alex is done
wxx is done
yxx is done
主

进程只要start就会在开始运行了,所以p1-p3.start()时,系统中已经有3个并发的进程了
而我们p1.join()是在等p1结束,没错p1只要不结束主线程就会一直卡在原地,这也是问题的关键
join是让主线程等,而p1-p3仍然是并发执行的,p1.join的时候,其余p2,p3仍然在运行,等#p1.join结束,可能p2,p3早已经结束了,这样p2.join,p3.join直接通过检测,无需等待
所以3个join花费的总时间仍然是耗费时间最长的那个进程运行的时间
上述例子可以简写成如下:

from multiprocessing import Process
import time,randomdef piao(name):print('%s is piaoing' %name)time.sleep(random.randint(1,3))print('%s is done' %name)if __name__ == '__main__':p1=Process(target=piao,args=('alex',))p2=Process(target=piao,args=('wxx',))p3=Process(target=piao,args=('yxx',))p_l=[p1,p2,p3]for p in p_l:p.start()for p in p_l:p.join()print('主')

利用多进程实现ftp套接字

我们之前写过非多进程的tcp套接字通信,这里在贴出代码来看下
server

import socket
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind(("127.0.0.1",8081))
server.listen(5)
while True:conn,addr = server.accept()while True:data = conn.recv(1024)if not data:breakdataStr = data.decode("utf-8")print(dataStr)conn.send(dataStr.upper().encode("utf-8"))conn.close()server.close()

client

import socket
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(("127.0.0.1",8081))while True:msg = input("请输入:")if not msg:continueclient.send(msg.encode("utf-8"))data = client.recv(1024)print(data.decode("utf-8"))
client.close()

我们要为server端添加多进程(client不做修改)

import socket
from multiprocessing import Processdef task(conn,addr):while True:try:msg = conn.recv(1024)if not msg:breakconn.send(msg.upper())except ConnectionResetError:breakif __name__ == "__main__":server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)server.bind(("127.0.0.1", 6087))server.listen(5)while True:conn, addr = server.accept()p = Process(target=task,args=(conn,addr))p.start()

这里写图片描述

这篇关于python基础-Process创建进程、join方法、实现ftp多进程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1125191

相关文章

Android实现悬浮按钮功能

《Android实现悬浮按钮功能》在很多场景中,我们希望在应用或系统任意界面上都能看到一个小的“悬浮按钮”(FloatingButton),用来快速启动工具、展示未读信息或快捷操作,所以本文给大家介绍... 目录一、项目概述二、相关技术知识三、实现思路四、整合代码4.1 Java 代码(MainActivi

python中各种常见文件的读写操作与类型转换详细指南

《python中各种常见文件的读写操作与类型转换详细指南》这篇文章主要为大家详细介绍了python中各种常见文件(txt,xls,csv,sql,二进制文件)的读写操作与类型转换,感兴趣的小伙伴可以跟... 目录1.文件txt读写标准用法1.1写入文件1.2读取文件2. 二进制文件读取3. 大文件读取3.1

使用Python实现一个优雅的异步定时器

《使用Python实现一个优雅的异步定时器》在Python中实现定时器功能是一个常见需求,尤其是在需要周期性执行任务的场景下,本文给大家介绍了基于asyncio和threading模块,可扩展的异步定... 目录需求背景代码1. 单例事件循环的实现2. 事件循环的运行与关闭3. 定时器核心逻辑4. 启动与停

基于Python实现读取嵌套压缩包下文件的方法

《基于Python实现读取嵌套压缩包下文件的方法》工作中遇到的问题,需要用Python实现嵌套压缩包下文件读取,本文给大家介绍了详细的解决方法,并有相关的代码示例供大家参考,需要的朋友可以参考下... 目录思路完整代码代码优化思路打开外层zip压缩包并遍历文件:使用with zipfile.ZipFil

Python处理函数调用超时的四种方法

《Python处理函数调用超时的四种方法》在实际开发过程中,我们可能会遇到一些场景,需要对函数的执行时间进行限制,例如,当一个函数执行时间过长时,可能会导致程序卡顿、资源占用过高,因此,在某些情况下,... 目录前言func-timeout1. 安装 func-timeout2. 基本用法自定义进程subp

Python实现word文档内容智能提取以及合成

《Python实现word文档内容智能提取以及合成》这篇文章主要为大家详细介绍了如何使用Python实现从10个左右的docx文档中抽取内容,再调整语言风格后生成新的文档,感兴趣的小伙伴可以了解一下... 目录核心思路技术路径实现步骤阶段一:准备工作阶段二:内容提取 (python 脚本)阶段三:语言风格调

Python结合PyWebView库打造跨平台桌面应用

《Python结合PyWebView库打造跨平台桌面应用》随着Web技术的发展,将HTML/CSS/JavaScript与Python结合构建桌面应用成为可能,本文将系统讲解如何使用PyWebView... 目录一、技术原理与优势分析1.1 架构原理1.2 核心优势二、开发环境搭建2.1 安装依赖2.2 验

C#实现将Excel表格转换为图片(JPG/ PNG)

《C#实现将Excel表格转换为图片(JPG/PNG)》Excel表格可能会因为不同设备或字体缺失等问题,导致格式错乱或数据显示异常,转换为图片后,能确保数据的排版等保持一致,下面我们看看如何使用C... 目录通过C# 转换Excel工作表到图片通过C# 转换指定单元格区域到图片知识扩展C# 将 Excel

Android Mainline基础简介

《AndroidMainline基础简介》AndroidMainline是通过模块化更新Android核心组件的框架,可能提高安全性,本文给大家介绍AndroidMainline基础简介,感兴趣的朋... 目录关键要点什么是 android Mainline?Android Mainline 的工作原理关键

基于Java实现回调监听工具类

《基于Java实现回调监听工具类》这篇文章主要为大家详细介绍了如何基于Java实现一个回调监听工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录监听接口类 Listenable实际用法打印结果首先,会用到 函数式接口 Consumer, 通过这个可以解耦回调方法,下面先写一个