文章网站的一级二级怎么做,东莞公共资源交易中心,陇南市武都区住房和城乡建设网站,网站优化seo怎么做如果你打算编写多进程的服务程序#xff0c;Unix/Linux无疑是正确的选择。由于Windows没有fork调用#xff0c;难道在Windows上无法用Python编写多进程的程序#xff1f; 由于Python是跨平台的#xff0c;自然也应该提供一个跨平台的多进程支持。multiprocessing模块就是跨…如果你打算编写多进程的服务程序Unix/Linux无疑是正确的选择。由于Windows没有fork调用难道在Windows上无法用Python编写多进程的程序 由于Python是跨平台的自然也应该提供一个跨平台的多进程支持。multiprocessing模块就是跨平台版本的多进程模块。 multiprocessing模块提供了一个Process类来代表一个进程对象下面的例子演示了启动一个子进程并等待其结束 #codingutf-8
from multiprocessing import Process
import os# 子进程要执行的代码
def run_proc(name):print(子进程运行中name %s ,pid%d... % (name, os.getpid()))if __name____main__:print(父进程 %d. % os.getpid())p Process(targetrun_proc, args(test,))print(子进程将要执行)p.start()p.join()print(子进程已结束) 运行结果: 父进程 13227.子进程将要执行子进程运行中name test ,pid13228, ppid13227子进程已结束 说明 创建子进程时只需要传入一个执行函数和函数的参数创建一个Process实例用start()方法启动这样创建进程比fork()还要简单。join()方法可以等待子进程结束后再继续往下运行通常用于进程间的同步。Process语法结构如下 Process([group [, target [, name [, args [, kwargs]]]]]) target表示这个进程实例所调用对象 args表示调用对象的位置参数元组 kwargs表示调用对象的关键字参数字典 name为当前进程实例的别名 group大多数情况下用不到 Process类常用方法 is_alive()判断进程实例是否还在执行 join([timeout])是否等待进程实例执行结束或等待多少秒 start()启动进程实例创建子进程 run()如果没有给定target参数对这个对象调用start()方法时就将执行对象中的run()方法 terminate()不管任务是否完成立即终止 Process类常用属性 name当前进程实例别名默认为Process-NN为从1开始递增的整数 pid当前进程实例的PID值 实例1 from multiprocessing import Process
import os
from time import sleep# 子进程要执行的代码
def run_proc(name, age, **kwargs):for i in range(10):print(子进程运行中name %s,age%d ,pid%d... % (name, age,os.getpid()))print(kwargs)sleep(0.5)if __name____main__:print(父进程 %d. % os.getpid())p Process(targetrun_proc, args(test,18), kwargs{m:20})print(子进程将要执行)p.start()sleep(1)p.terminate()p.join()print(子进程已结束) 运行结果: 父进程 21378.
子进程将要执行
子进程运行中name test,age18 ,pid21379...
{m: 20}
子进程运行中name test,age18 ,pid21379...
{m: 20}
子进程已结束 实例2 #codingutf-8
from multiprocessing import Process
import time
import os#两个子进程将会调用的两个方法
def worker_1(interval):print(worker_1,父进程(%s),当前进程(%s)%(os.getppid(),os.getpid()))t_start time.time()time.sleep(interval) #程序将会被挂起interval秒t_end time.time()print(worker_1,执行时间为%0.2f秒%(t_end - t_start))def worker_2(interval):print(worker_2,父进程(%s),当前进程(%s)%(os.getppid(),os.getpid()))t_start time.time()time.sleep(interval)t_end time.time()print(worker_2,执行时间为%0.2f秒%(t_end - t_start))#输出当前程序的ID
print(进程ID%s%os.getpid())#创建两个进程对象target指向这个进程对象要执行的对象名称
#args后面的元组中是要传递给worker_1方法的参数
#因为worker_1方法就一个interval参数这里传递一个整数2给它
#如果不指定name参数默认的进程对象名称为Process-NN为一个递增的整数
p1Process(targetworker_1,args(2,))
p2Process(targetworker_2,namedongGe,args(1,))#使用进程对象名称.start()来创建并执行一个子进程
#这两个进程对象在start后就会分别去执行worker_1和worker_2方法中的内容
p1.start()
p2.start()#同时父进程仍然往下执行如果p2进程还在执行将会返回True
print(p2.is_alive%s%p2.is_alive())#输出p1和p2进程的别名和pid
print(p1.name%s%p1.name)
print(p1.pid%s%p1.pid)
print(p2.name%s%p2.name)
print(p2.pid%s%p2.pid)#join括号中不携带参数表示父进程在这个位置要等待p1进程执行完成后
#再继续执行下面的语句一般用于进程间的数据同步如果不写这一句
#下面的is_alive判断将会是True在shellcmd里面调用这个程序时
#可以完整的看到这个过程大家可以尝试着将下面的这条语句改成p1.join(1)
#因为p2需要2秒以上才可能执行完成父进程等待1秒很可能不能让p1完全执行完成
#所以下面的print会输出True即p1仍然在执行
p1.join()
print(p1.is_alive%s%p1.is_alive()) 执行结果: 进程ID19866
p2.is_aliveTrue
p1.nameProcess-1
p1.pid19867
p2.namedongGe
p2.pid19868
worker_1,父进程(19866),当前进程(19867)
worker_2,父进程(19866),当前进程(19868)
worker_2,执行时间为1.00秒
worker_1,执行时间为2.00秒
p1.is_aliveFalse 转载于:https://www.cnblogs.com/Paul-watermelon/articles/9724588.html
