进程之间的通信process_queue

发表于 更新于 分类于
这是文章开头，显示在主页面，详情请点击此处。

简介 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
# coding:utf-8

import multiprocessing
import json,time

# 使用类来接收和发送消息,其实是用一个队列。

class Work(object):
    def __init__(self,q): # 在构造函数里定义一个队列对象q：要求传入一个队列 q，put 是进队列的方法。
        self.q = q
    def send(self,message):
        if not isinstance(message,str):  # 若不是字符串类型，这里有漏洞。
            message = json.dumps(message)  # 把message转为json格式存好。
        self.q.put(message)         # 进队列
    def send_all(self):
        for i in range(20):
            self.q.put(i)
            time.sleep(1)

    def receive(self):    # 不停的从队列中取
        while 1:
            result = self.q.get()
            try:
                res = json.loads(result)
            except:
                res = result
            print('recv is %s' % res)

if __name__=='__main__':
    q = multiprocessing.Queue()
    work = Work(q)
    send = multiprocessing.Process(target=work.send,args=({'name':111},))
    recv = multiprocessing.Process(target=work.receive)
    send_all_p = multiprocessing.Process(target=work.send_all)

    send_all_p.start()
    send.start()
    recv.start()
    
    # send.join()
    send_all_p.join()  #  把时间最长的进程阻塞掉就行了。
    
    recv.terminate()  # 手动终结无限循环的进程。