python：进程操作

发布时间：2020-12-17 00:01:12 所属栏目：Python 来源：网络整理

导读：一、多进程应用 multiprocessing span style="color: #0000ff"def span style="color: #000000" talk(conn): conn.send(b span style="color: #800000"' span style="color: #800000"connected span style="color: #800000"' span style="color: #000000") r

一、多进程应用

multiprocessing def talk(conn):
conn.send(b'connected')
ret = conn.recv(1024)
print(ret)

=,8080= sk.recv(1024= input(>>

二、进程中的其他方法

multiprocessing (*1015(*10def cal_time():
while True:
time.sleep(1)
print('过去了1秒')

if name == 'main':
p = Process(target=cal_time)
p.daemon = True #守护进程：一定在开启进程之前设置
 p.start()
p2 = Process(target=func) # 15s
 p2.start()
for i in range(100): # 10s
time.sleep(0.1)
print(''i)
p2.join()

1，start()开启一个进程

join：用join可以让主进程等待子进程结束

守护进程会随着主进程的代码执行结束而结束

正常的子进程没有执行完的时候主进程要一直等着

2）守护进程的作用

会随着主进程的代码执行结束而结束,不会等待其他子进程

3）注意：

守护进程要在start之间设置

守护进程中不能再开启子进程

2，is_alive与terminate

multiprocessing (5( == = Process(target=0.11(p.is_alive())

p.is_alive()   # 是否活着 True代表进程还在 False代表进程不在了p.terminate()  # 结束一个进程,但是这个进程不会立刻被杀死

(5( == = Process(target== class MyProcess(Process):
def run(self):
print('wahaha',self.name,self.pid)
time.sleep(5)
print('qqxing',self.pid)
if name == 'main':
p = MyProcess()
p.start()
print(p.pid)
# pid 查看这个进程进程id

name 查看这个进程的名字

三、锁

multiprocessing Lock lock = Lock() lock.acquire() lock.acquire()

锁 就是在并发编程中 保证数据安全

multiprocessing multiprocessing def search(i):
with open('ticket') as f:
print(i,json.load(f)['count'])

def get(i):
with open('ticket') as f:
ticket_num = json.load(f)['count']
time.sleep(random.random())
if ticket_num > 0:
with open('ticket','w') as f:
json.dump({'count':ticket_num-1},f)
print('%s买到票了'%i)
else:
print('%s没票了'%i)

def task(i,lock):
search(i) # 查看票
 lock.acquire()
get(i) # 抢票
 lock.release()

if name == 'main':
lock = Lock()
for i in range(20): # 20个人同时抢票
p = Process(target=task,args=(i,lock))
p.start()
import json
import time
import random
from multiprocessing import Lock
from multiprocessing import Process

def search(i):
with open('ticket') as f:
print(i,lock))
p.start()

四、信号量

multiprocessing Semaphore multiprocessing (%1,10(% == = Semaphore(4 i range(20=sing,sem)).start()

五、事件

事件 —— 异步阻塞事件是所有的进程，都陷入阻塞

multiprocessing Event

multiprocessing multiprocessing 3( 3(

def car(i,e):
e.wait()
print('%s车通过'%i)

if name == 'main':
e = Event() # 立一个红灯
tra = Process(target=traffic_light,args=(e,))
tra.start() # 启动一个进程来控制红绿灯
for i in range(100):
if i%6 == 0 :
time.sleep(random.randint(1,3))
car_pro = Process(target=car,e))
car_pro.start()

六、队列

队列进程之间的通信

1.进程之间通信 可以使用multiprocessing 的 Queue模块2.队列有两种创建方式 第一种不传参数 这个队列就没有长度限制 ；传参数，创建一个有最大长度限制的队列3.提供两个重要方法；put get4.qsize查看队列的大小

producer(q): i range(100%def consumer(q): # 消费者
for i in range(100):
time.sleep(1)
print(q.get())

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

python：进程操作

<span style="color: #008000"> name 查看这个进程的名字