進(jìn)程之間有很多通信的方式导而，除了socket献雅，還有pipe和queue。
pipe
#encoding:utf-8
import multiprocessing
def proc1(pipe):
pipe.send("hello")
print ("proc 1 : ",pipe.recv())
def proc2(pipe):
print ("proc 2 : ",pipe.recv())
pipe.send("hello ,too")
#創(chuàng)建一個(gè)管道 這個(gè)管道是雙向的
pipe=multiprocessing.Pipe()
#pipe[0] 表示管道的一端占锯，pipe[1] 表示管道的另外一端
#對ｐｉｐｅ的某一端調(diào)用ｓｅｎｄ方法來傳送對象袒哥，在另外一端使用ｒｅｃｖ來接收
p1=multiprocessing.Process(target=proc1,args=(pipe[0],))
p2=multiprocessing.Process(target=proc2,args=(pipe[1],))
p1.start()
p2.start()
p1.join()
p1.join()
queue
#encoding:utf-8
import multiprocessing
import time
import os
def inputq(queue):
info=str(+os.getpid())+ ' put : '+str(time.ctime())
queue.put(info)
time.sleep(2)
info=queue.get()
print (info)
def outputq(queue):
info=queue.get()
print (info)
queue.put(str(time.ctime()))
queue=multiprocessing.Queue(10)
p1=multiprocessing.Process(target=inputq,args=(queue,))
p2=multiprocessing.Process(target=outputq,args=(queue,))
p1.start()
p2.start()
p1.join()
p2.join()
順便提一下，兩個(gè)進(jìn)程的去訪問一個(gè)全局變量的情況
在python里面創(chuàng)建兩個(gè)進(jìn)程消略，兩個(gè)進(jìn)程同時(shí)去訪問堡称，修改一個(gè)全局變量i∫昭荩看看這兩個(gè)進(jìn)程其中一個(gè)進(jìn)程修改全局變量i却紧，另外一個(gè)進(jìn)程去訪問變量，看看這個(gè)變量是否被修改胎撤。
執(zhí)行如下代碼：
from time import sleep,ctime
from multiprocessing import Process
i=100
def proc1():
global i
count=1
while True:
print ('proc1 >>',i)
i=i+2
sleep(1)
if count==5:
break
count=count+1
def proc2():
global i
count=1
while True:
print ('proc2 >>>>>>>>',i)
i=i-3
sleep(1)
if count==5:
break
count=count+1
print ("start")
p1=Process(target=proc1)
p2=Process(target=proc2)
p1.start()
p2.start()
p1.join()
p2.join()
print ("end")
看一下運(yùn)行結(jié)果：
可以看到晓殊，一個(gè)進(jìn)程修改全變變量，另外一個(gè)進(jìn)程根本不會(huì)影響伤提。
對這個(gè)問題的回答挺物，就要涉及到進(jìn)程的內(nèi)存模型了，每個(gè)進(jìn)程的內(nèi)存空間都是獨(dú)立的飘弧，都是4G，每個(gè)內(nèi)存空間都是獨(dú)立的砚著，有自己的代碼段次伶，數(shù)據(jù)段，堆稽穆，棧等冠王。所以，一個(gè)進(jìn)程更改變量舌镶，另外一個(gè)進(jìn)程根本不會(huì)受到影響柱彻。
demo4,5
下面的要講的是，進(jìn)程的通信的方式餐胀，比如隊(duì)列queue和pipe來實(shí)現(xiàn)進(jìn)程通信哟楷。
關(guān)于queue，有一個(gè)是線程安全的否灾，有一個(gè)是線程不安全的卖擅。
1.from Queue import Queue
這個(gè)是普通的隊(duì)列模式，類似于普通列表，先進(jìn)先出模式惩阶，get方法會(huì)阻塞請求挎狸，直到有數(shù)據(jù)get出來為止
2.from multiprocessing.Queue import Queue
這個(gè)是多進(jìn)程并發(fā)的Queue隊(duì)列，用于解決多進(jìn)程間的通信問題断楷。普通Queue實(shí)現(xiàn)不了锨匆。
例如來跑多進(jìn)程對一批IP列表進(jìn)行運(yùn)算，運(yùn)算后的結(jié)果都存到Queue隊(duì)列里面冬筒，這個(gè)就必須使用multiprocessing提供的Queue來實(shí)現(xiàn)
舉個(gè)例子：
#import Queue
from time import sleep,ctime
from multiprocessing import Process,Queue
def pro1(q):
while True:
val=q.get(True)
print '>>>>in por1:',val
def pro2(q):
while True:
val=q.get(True)
print 'in por2:',val
q=Queue()
for i in range(101):
q.put(i)
print 'start : ',ctime()
p1=Process(target=pro1,args=(q,))
p2=Process(target=pro2,args=(q,))
p1.start()
p2.start()
sleep(20)
print 'end : ',ctime()
pr.terminate()
運(yùn)行結(jié)果：
分析運(yùn)行結(jié)果恐锣，這是一個(gè)進(jìn)程安全的隊(duì)列，如果隊(duì)列里面存放這個(gè)0-29账千，如果這個(gè)數(shù)字被進(jìn)程pro1 被get侥蒙，那么這個(gè)數(shù)字就不在了。所以匀奏，0-29只會(huì)被print一次鞭衩。
下面再舉一個(gè)普通queue的例子，代碼如下：
#coding:utf-8
import Queue
from time import sleep,ctime
#from multiprocessing import Queue
from multiprocessing import Process
def pro1(q):
while True:
val=q.get(True)
print '>>>>in por1:',val
def pro2(q):
while True:
val=q.get(True)
print 'in por2:',val
#如果頭文件是import Queue
q=Queue.Queue()
#如果頭文件是from multiprocessing import Queue 娃善，那執(zhí)行
#q=Queue()
for i in range(20):
q.put(i)
print 'start : ',ctime()
p1=Process(target=pro1,args=(q,))
p2=Process(target=pro2,args=(q,))
p1.start()
p2.start()
sleep(20)
print 'end : ',ctime()
pr.terminate()
運(yùn)行結(jié)果：
普通隊(duì)列论衍，兩個(gè)進(jìn)程都會(huì)把隊(duì)列里面的數(shù)字各打印一次,線程安全的隊(duì)列只是打印一次。
