首页 / PYTHON / Python随心记--进程调用
Python随心记--进程调用
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Python随心记--进程调用，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4395字，纯文字阅读大概需要7分钟。
内容图文
进程调用
from multiprocessing import Process
import time
def f(name):
time.sleep(1)
print(‘hello‘,name,time.ctime())
if__name__ == ‘__main__‘:
p_list = []
for i in range(3):
p = Process(target=f,args=(‘alive‘,))
p_list.append(p)
p.start()
for i in p_list:
p.join()
print(‘end‘)
from multiprocessing import Process
import time
class MyProcess(Process):
# def __init__(self):# super(MyProcess,self).__init__()def run(self):
time.sleep(1)
print(‘hello‘,self.name,time.ctime())
if__name__ == ‘__main__‘:
p_list = []
for i in range(3):
p = MyProcess()
p.daemon = True #守护进程 p.start()
p_list.append(p)
# for i in p_list:# p.join()print(‘end‘)
from multiprocessing import Process
import time,os
def info(title):
print(‘title:‘,title)
print(‘parent process:‘,os.getppid())
print(‘process id:‘,os.getpid())
def f(name):
info(‘function f‘)
print(‘hello‘,name)
if__name__ == ‘__main__‘:
info(‘main process line‘)
time.sleep(1)
print(‘---------------‘)
p = Process(target=info,args=(‘lin‘,))
p.start()
p.join()
#is_alivefrom multiprocessing import Process
import time
class MyProcess(Process):
def__init__(self,num):
super(MyProcess,self).__init__()
self.num = num
def run(self):
time.sleep(2)
print(self.pid)
print(self.is_alive())
print(self.num)
if__name__ == ‘__main__‘:
p_list = []
for i in range(10):
p = MyProcess(i)
p_list.append(p)
for i in p_list:
i.start()
进程通讯
Process([group[,target[,name[,args[,kwargs]]]]])
group:线程组，目前还没实现，库引用中提示必须是None
target:要执行的方法
name:进程名
args/kwargs:传入的参数
实例方法
#is_alive():返回进程是否在进行
#join() 阻塞
#start() 开启
#run() start()调用run方法
#terminate() 终止任务
属性
daemon
......
队列通讯
import
multiprocessing
import
queue,time
def
foo(q):
time.sleep(1)
print(q(id))
q.put(13)
q.put(‘achun‘)
if__name__ == ‘__main__‘:
# q = queue.Queue()
q = multiprocessing.Queue()
p = multiprocessing.Process(target=foo,args=(q,))
p.start()
p.join()
print(q.get())
print(q.get())
管道通信
from multiprocessing import Process,Pipe
def f(conn):
conn.send([112,{‘name‘:‘lin‘},‘hello‘])
respones = conn.recv()
print(‘respones‘,respones)
conn.close()
print(‘q_ID2：‘,id(conn))
if__name__ == ‘__main__‘:
parent_conn,child_conn = Pipe() #双向管道print(‘q_ID2：‘, id(child_conn))
p = Process(target=f,args=(child_conn,))
p.start()
print(parent_conn.recv())
parent_conn.send(‘hello,hao are you‘)
p.join()
进程通信 资源(数据)共享
from multiprocessing import Process,Manager
def f(d,l,n):
d[n] = ‘1‘
d[‘2‘] = 2
d[0,25] = None
l.append(n)
if__name__ == ‘__main__‘:
with Manager() as manager:
d = manager.dict()
l = manager.list(range(5))
print(‘main process:‘,id(d),id(l))
p_list = []
for i in range(10):
p = Process(target=f,args=(d,l,i))
p.start()
p_list.append(p)
for res in p_list:
res.join()
print(d)
print(l)
进程同步
from multiprocessing import Process,Lock
def f(l,i):
with l:
print(‘hello world %s ‘ %i)
if__name__ == ‘__main__‘:
lock = Lock()
for num in range(10):
Process(target=f,args=(lock,num)).start()
进程池
from multiprocessing import Process,Pool
import time,os
def Foo(i):
time.sleep(1)
print(i)
return i+100
def Bar(arg):
print(os.getpid())
print(os.getppid())
print(‘logger:‘,arg)
# Bar(1)if__name__ == ‘__main__‘:
pool = Pool(5) # 创建进程池对象（限制为5个）for i in range(100):
# pool.apply(func = Foo,args = (i,)) #同步
pool.apply_async(func = Foo,args = (i,),callback = Bar) #异步
pool.close()
pool.join()
print(‘ending...........‘)
协程：协作式（协程是非抢占式的程序）----（生成器）（yield(协程)）
#优势1没有切换的消耗
# 2没有锁的概念
import
time,queue
def
consumer(name):
print(‘.................‘)
while True:
new_baozi = yieldprint(‘[%s] is eating baozi %s‘ %(name,new_baozi))
def product():
r = con.__next__()
r = con2.__next__()
n = 0
while 1:
time.sleep(1)
print(‘\033[32;1m[product]\033[0m is making %s and %s‘ %(n,n+1))
con.send(n)
con2.send(n+1)
n += 2
if__name__ == ‘__main__‘:
con = consumer(‘c1‘)
con2 = consumer(‘c2‘)
product()
greenlet 自主切换执行顺序
from greenlet import greenlet
def test1():
print(12)
gr2.switch()
print(34)
gr2.switch()
def test2():
print(56)
gr1.switch()
print(78)
gr1 = greenlet(test1)
gr2 = greenlet(test2)
gr2.switch()
import gevent,request,time
start = time.time()
def f(url):
print(‘GET:%s‘ %url)
resp = request.get(url)
data = resp.text
print(‘%d bytes received from %s.‘ %(len(data),url))
gevent.joinall([
gevent.spawn(f,‘https://www.python.org/‘),
gevent.spawn(f,‘https://www.baidu.org/‘),
gevent.spawn(f,‘https://www.Yutube.org/‘),
])
print(‘cost time:‘,time.time()- start)
原文：https://www.cnblogs.com/Essaycode/p/10325243.html
内容总结
以上是互联网集市为您收集整理的Python随心记--进程调用全部内容，希望文章能够帮你解决Python随心记--进程调用所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】