python基础一 day36 多进程

「爱情、让人受尽委屈。」 2024-04-20 11:06 98阅读 0赞

1.多进程：

import os  
import time  
from multiprocessing import Process  
def func(args,args2):  
print(args,args2)  
time.sleep(3)  
print('子进程 :', os.getpid())  
print('子进程的父进程 :', os.getppid())  
print(12345)

if \_\_name\_\_ == '\_\_main\_\_':  
p = Process(target=func,args=('参数','参数2')) \# 注册  
\# p是一个进程对象,还没有启动进程  
p.start() \# 开启了一个子进程  
print('\*'\*10)  
print('父进程 :',os.getpid()) \# 查看当前进程的进程号  
print('父进程的父进程 :',os.getppid()) \# 查看当前进程的父进程

\# 进程的生命周期  
\# 主进程  
\# 子进程  
\# 开启了子进程的主进程 :  
\# 主进程自己的代码如果长,等待自己的代码执行结束,  
\# 子进程的执行时间长,主进程会在主进程代码执行完毕之后等待子进程执行完毕之后 主进程才结束

2.多进程中的几个方法

\# join()  
import time  
from multiprocessing import Process

def func(arg1,arg2):  
print('\*'\*arg1)  
time.sleep(5)  
print('\*'\*arg2)

if \_\_name\_\_ == '\_\_main\_\_':  
p = Process(target=func,args=(10,20))  
p.start()  
print('hahahaha')  
p.join() \# 是感知一个子进程的结束,将异步的程序改为同步  
print('====== : 运行完了')

3.开启多个子进程

import os  
import time  
from multiprocessing import Process

def func(filename,content):  
with open(filename,'w') as f:  
f.write(content\*10\*'\*')

if \_\_name\_\_ == '\_\_main\_\_':  
p\_lst = \[\]  
for i in range(10):  
p = Process(target=func,args=('info%s'%i,0))  
p\_lst.append(p)  
p.start()  
for p in p\_lst:p.join() \# 之前的所有进程必须在这里都执行完才能执行下面的代码  
print(\[i for i in os.walk(r'E:\\python10\\day37')\])

\# 同步 0.1 \* 500 = 50  
\# 异步 500 0.1 = 0.1  
\# 多进程写文件  
\# 首先往文件夹中写文件  
\# 向用户展示写入文件之后文件夹中所有的文件名

4.开启多进程的第二种方式

import os  
from multiprocessing import Process

class MyProcess(Process):  
def \_\_init\_\_(self,arg1,arg2):  
super().\_\_init\_\_()  
self.arg1 = arg1  
self.arg2 = arg2

def run(self):  
print(self.pid)  
print(self.name)  
print(self.arg1)  
print(self.arg2)

if \_\_name\_\_ == '\_\_main\_\_':  
p1 = MyProcess(1,2)  
p1.start()  
p2 = MyProcess(3,4)  
p2.start()

\# 自定义类 继承Process类  
\# 必须实现一个run方法,run方法中是在子进程中执行的代码

5.多进程之间的数据隔离问题

\# 进程 与 进程之间  
import os  
from multiprocessing import Process

def func():  
global n \# 声明了一个全局变量  
n = 0 \# 重新定义了一个n  
print('pid : %s'%os.getpid(),n)

if \_\_name\_\_ == '\_\_main\_\_':  
n = 100  
p = Process(target=func)  
p.start()  
p.join()  
print(os.getpid(),n)

6.守护进程

\# 子进程 -- > 守护进程  
import time  
from multiprocessing import Process

def func():  
while True:  
time.sleep(0.2)  
print('我还活着')

def func2():  
print('in func2 start')  
time.sleep(8)  
print('in func2 finished')

if \_\_name\_\_ == '\_\_main\_\_':  
p = Process(target=func)  
p.daemon = True \# 设置子进程为守护进程  
p.start()  
p2 = Process(target=func2)  
p2.start()  
p2.terminate() \# 结束一个子进程  
time.sleep(1)  
print(p2.is\_alive()) \# 检验一个进程是否还活着  
print(p2.name)  
\# i = 0  
\# while i<5:  
\# print('我是socket server')  
\# time.sleep(1)  
\# i+=1

\# 守护进程 会 随着 主进程的代码执行完毕 而 结束  
\# 在主进程内结束一个子进程 p.terminate()  
\# 结束一个进程不是在执行方法之后立即生效,需要一个操作系统响应的过程  
\# 检验一个进程是否活着的状态 p.is\_alive()  
\# p.name p.pid 这个进程的名字和进程号

7.锁

\# 锁

\# 火车票  
import json  
import time  
from multiprocessing import Process  
from multiprocessing import Lock

\# def show(i):  
\# with open('ticket') as f:  
\# dic = json.load(f)  
\# print('余票: %s'%dic\['ticket'\])

def buy\_ticket(i,lock):  
lock.acquire() \#拿钥匙进门  
with open('ticket') as f:  
dic = json.load(f)  
time.sleep(0.1)  
if dic\['ticket'\] > 0 :  
dic\['ticket'\] -= 1  
print('\\033\[32m%s买到票了\\033\[0m'%i)  
else:  
print('\\033\[31m%s没买到票\\033\[0m'%i)  
time.sleep(0.1)  
with open('ticket','w') as f:  
json.dump(dic,f)  
lock.release() \# 还钥匙

if \_\_name\_\_ == '\_\_main\_\_':  
\# for i in range(10):  
\# p = Process(target=show,args=(i,))  
\# p.start()  
lock = Lock()  
for i in range(10):  
p = Process(target=buy\_ticket, args=(i,lock))  
p.start()

转载于:https://www.cnblogs.com/wang-tan/p/11432128.html