python 进程 进程池 进程间通信实现解析

from multiprocessing import Processimport timedef test_():  print '-----test-----'if __name__ == '__main__':  p = Process(target=test_)  p.start()  while True:    print '--main--'    '''1.通过process 类创建一个进程对象，然后start即可开启进程， testtest_函数是进程实现的功能'''  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'''

from multiprocessing import Poolfrom time import sleepimport 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()

'''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, Queueimport timeq = 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 edef test_b():  try:    while True:      num = q.get_nowait()      print '我是进程b 取出数字是:%s'%num      time.sleep(1)  except Exception, e:    print eif __name__ == '__main__':  p1 = Process(target=test_a)  p2 = Process(target=test_b)  p1.start()  p2.start()