multiprocessing 的 pipe 和 queque

[wangfeng3769]

#coding:utf-8
import re
import os
import requests as R
from BeautifulSoup import BeautifulSoup as BS
import multiprocessing
import urlparse
import time
Q = multiprocessing.Queue()
a,b = multiprocessing.Pipe()
def r_mess():
print "r_mess"
while 1:
print 'get'
# q = Q.get()
print b.recv()
print get
print q

def s_mess():
print "s_mess"
for i in xrange(984):
# print i
# Q.put(i)
a.send(i)

if __name__ == "__main__":
multiprocessing.freeze_support()
m1 = multiprocessing.Process(target=s_mess)
m2 = multiprocessing.Process(target=r_mess)
m1.start()
m2.start()
m1.join()
m2.join()

代码吗就是这么简单，想说的就是windows下的multiprocessing 启动线程没有问题，就是线程之间利用pipe 或者queue通信是被阻塞的，希望哥们给出个好的建议。

[yuelang85]

缩进。。。。不应该是进程吗？