python 進(jìn)程 進(jìn)程池 進(jìn)程間通信實現(xiàn)解析

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 類創(chuàng)建一個進(jìn)程對象，然后start即可開啟進(jìn)程， test
test_函數(shù)是進(jìn)程實現(xiàn)的功能'''
 
 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 方法 里邊實現(xiàn) 進(jìn)程功能 
 創(chuàng)建對象之后 調(diào)用start'''

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()

'''python 進(jìn)程間通信   Queue '''

'''1.Queue使用方法
  1.Queue.qsize(): 返回當(dāng)前隊列包含的消息數(shù)量
  2.Queue.empty(): 如果隊列為空 返回True 反之 False
  3.Queue.full(): 如果隊列滿了返回True 反之 False
  4.Queue.get():  獲取隊列中一條消息 然后將其從隊列中移除 可傳參數(shù) 超市時長
  Queue.get_nowait(): 相當(dāng)于 Queue.get(False) 取不到值 觸發(fā)異常
  Queue.put(): 將一個值添加到數(shù)列 可傳參數(shù) 超時時長
  Queue.put_nowait():相當(dāng)于 Queue.get(False) 當(dāng)隊列滿時 報錯
'''
from multiprocessing import Process, Queue
import time
q = Queue() # 創(chuàng)建隊列
for i in range(10):
  q.put(i)    
def test_a():
    try:
      while True:
        num = q.get_nowait()
        print '我是進(jìn)程a 取出數(shù)字為:%s'%num
        time.sleep(1)
    except Exception, e:
      print e
def test_b():
  try:
    while True:
      num = q.get_nowait()
      print '我是進(jìn)程b 取出數(shù)字是:%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()