标签：port 字典 相互 传参 return 进程 for war 详解
进程:通俗理解一个运行的程序或者软件,进程是操作系统资源分配的基本单位
1.1、导入进程模块
import multiprocessing
1.2、Process进程类的语法结构如下：
Process([group[, target[, name[,args[,kwargs]]]]])
group: --指定进程组，目前只能使用None
target: --执行的目标任务名
name: --进程名字
args: --以元组方式给执行任务传参
kwargs: --以字典方式给执行任务传参
Process创建 的实例对象的常用方法：
start(), 启动子进程实例（创建子进程）
join(timeout), 是否等待子进程执行结束，或等待多少秒
terminate(), 不管任务是否完成，立即终止进程
Process创建的实例对象的常用属性：
name 当前进程的别名，默认为Process-N,N为从1开始递增的整数。
pid 当前进程的pid（进程号）
一、多进程完成多任务代码
1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 """ 4 python进程 5 """ 6 import multiprocessing 7 import time 8 9 def run_proc(): 10 """ 11 子进程要执行的代码 12 :return: 13 """ 14 while True: 15 print("---2---") 16 time.sleep(1) 17 18 if __name__ == "__main__": 19 #创建子进程 20 sub_process = multiprocessing.Process(target=run_proc) 21 #启动子进程 22 sub_process.start() 23 while True: 24 print("----1----") 25 time.sleep(1)
代码执行结果：
二、获取进程pid
1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 """ 4 获取进程pid 5 """ 6 7 import multiprocessing 8 import time 9 import os 10 11 def work(): 12 #查看当前进程 13 current_process = multiprocessing.current_process() 14 print("work:", current_process) 15 #获取当前进程的编号 16 print("work进程编号:", current_process.pid, os.getpid()) 17 #获取父进程的编号 18 print("work父进程的编号：", os.getppid()) 19 for i in range(10): 20 print("工作中....") 21 time.sleep(0.2) 22 #扩展，根据进程编号杀死对应的进程 23 os.kill(os.getpid(), 9) 24 25 if __name__ == "__main__": 26 #查看当前进程 27 current_process = multiprocessing.current_process() 28 print("main:", current_process) 29 #获取当前里程的编号 30 print("main进程的编号：", current_process.pid) 31 32 #创建子进程 33 sub_process = multiprocessing.Process(target=work) 34 #启动进程 35 sub_process.start() 36 37 #主进程执行打印信息操作 38 for i in range(5): 39 print("我在主进程中执行....") 40 time.sleep(0.2)
代码执行结果：
三、进程的基本状态及状态之间的关系
1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 """ 4 给子进程指定的函数传递参数 5 """ 6 7 import multiprocessing 8 9 #定义一个用于显示信息的方法 10 def show_info(name, age): 11 print("name:", name, "; age:", age) 12 13 if __name__ == "__main__": 14 sub_process = multiprocessing.Process(target=show_info, args=("yusheng_liang", 20)) 15 #启动进程 16 sub_process.start()
代码执行结果：
四、进程之间不共享全局变量
注意:创建子进程其实是对主进程进行拷贝，进程之间相互独立，访问的全局变量不是同一个，所以进程之间不共享全局变量
#!/usr/bin/env python # -*- coding:utf-8 -*- """ 进程之间不共享全局变量 """ import multiprocessing import time #定义全局变量 my_list = list() #定义写入数据的方法 def write_data(): for i in range(5): my_list.append(i) time.sleep(0.2) print("write_data: ", my_list) #定义读取数据的方法 def read_data(): print("read_data: ", my_list) if __name__ == "__main__": #创建写入数据的进程 write_process = multiprocessing.Process(target=write_data) #创建读取数据的进程 read_process = multiprocessing.Process(target=read_data) write_process.start() #主进程等待写入进程执行完成以后代码，再继续往下执行 write_process.join() read_process.start()
代码执行结果：
五、主进程会等待所有的子进程执行完成程序再退出
1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 """ 4 主进程会等待所有的子进程执行完成程序再退出 5 """ 6 import multiprocessing 7 import time 8 9 #测试子进程是否执行完成以后主进程才能退出 10 def work(): 11 for i in range(7): 12 print("工作中.....") 13 time.sleep(0.2) 14 15 if __name__ == "__main__": 16 #创建子进程 17 work_process = multiprocessing.Process(target=work) 18 work_process.start() 19 20 #让主进程等待1秒钟 21 time.sleep(1) 22 print("主进程执行完成了啦！！") 23
代码执行结果：
六、销毁子进程的代码
1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 """ 4 主进程会等待所有的子进程执行完成程序再退出 5 """ 6 import multiprocessing 7 import time 8 9 #测试子进程是否执行完成以后主进程才能退出 10 def work(): 11 for i in range(7): 12 print("工作中.....") 13 time.sleep(0.2) 14 15 if __name__ == "__main__": 16 #创建子进程 17 work_process = multiprocessing.Process(target=work) 18 work_process.start() 19 20 #让主进程等待1秒钟 21 time.sleep(1) 22 print("主进程执行完成了啦！！") 23 24 #让子进程直接销毁，表示终止执行，主进程退出之前，把所有的子进程直接销毁就可以了 25 work_process.terminate()
代码执行的结果：
标签：port 字典 相互 传参 return 进程 for war 详解
原文地址：https://www.cnblogs.com/june-L/p/11795765.html
