python 进程 进程池 进程间通信

Posted 南鱼

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python 进程 进程池 进程间通信相关的知识,希望对你有一定的参考价值。

1.python 中创建进程的两种方式:

from multiprocessing import Process
import time
def test_():
    print -----test-----
if __name__ == __main__:
    p = Process(target=test_)
    p.start()
    while True:
        print --main--
        

‘‘‘1.通过process 类创建一个进程对象,然后start即可开启进程, test
test_函数是进程实现的功能‘‘‘
 
 from multiprocessing import Process
 import time
 class MyNewProcess(Process):
     def run(self):
         print ------run-------
 if __name__ == __main__:
     p = MyNewProcess()
     p.start()
     print ---main-----
 ‘‘‘2.通过类似继承process   子类中必须有run 方法 里边实现 进程功能 
 创建对象之后 调用start‘‘‘

2.进程池

from multiprocessing import Pool
from time import sleep
import os


def func(num):
    for i in range(3):
        print ‘%s %s‘ %(os.getpid(),num) #
        sleep(2)


def main():
    pool = Pool(3)
    for i in range(3, 6):
        res = pool.apply_async(func, (i,))
    pool.close()
    pool.join()


if __name__ == ‘__main__‘:
    main()

3.进程间通信

‘‘‘python 进程间通信     Queue ‘‘‘

‘‘‘1.Queue使用方法
    1.Queue.qsize(): 返回当前队列包含的消息数量
    2.Queue.empty(): 如果队列为空 返回True 反之 False
    3.Queue.full():  如果队列满了返回True 反之 False
    4.Queue.get():   获取队列中一条消息 然后将其从队列中移除 可传参数 超市时长
    Queue.get_nowait(): 相当于 Queue.get(False) 取不到值 触发异常
    Queue.put(): 将一个值添加到数列 可传参数 超时时长
    Queue.put_nowait():相当于 Queue.get(False)  当队列满时 报错
‘‘‘


from multiprocessing import Process, Queue
import time

q = Queue()  # 创建队列
for i in range(10):
    q.put(i)
    
    
def test_a():
        try:
            while True:
                num = q.get_nowait()
                print 我是进程a 取出数字为:%s%num
                time.sleep(1)
        except Exception, e:
            print e


def test_b():
    try:
        while True:
            num = q.get_nowait()
            print 我是进程b 取出数字是:%s%num
            time.sleep(1)
    except Exception, e:
        print e


if __name__ == __main__:
    p1 = Process(target=test_a)
    p2 = Process(target=test_b)
    p1.start()
    p2.start()

至此  简单得使用已经结束   

以上是关于python 进程 进程池 进程间通信的主要内容,如果未能解决你的问题,请参考以下文章

python基础之进程间通信进程池协程

Python开发基础--- 进程间通信进程池协程

python 进程 进程池 进程间通信

python全栈开发day32-进程创建,进程同步,进程间的通信,进程池

python全栈开发,Day40(进程间通信(队列和管道),进程间的数据共享Manager,进程池Pool)

Python使用进程池管理进程和进程间通信