欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

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

系統(tǒng) 1667 0

1.python 中創(chuàng)建進程的兩種方式:

            
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)建一個進程對象,然后start即可開啟進程, test
test_函數(shù)是進程實現(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) 進程功能 
 創(chuàng)建對象之后 調(diào)用start'''
          

2.進程池

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

3.進程間通信

            
'''python 進程間通信   Queue '''

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

至此 簡單得使用已經(jīng)結(jié)束

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 国产精品高清在线观看 | 亚洲精品久久久久无码AV片软件 | 精品一区二区三区在线观看 | 成人18网站| 亚洲综合影院 | 成人欧美一级毛片免费观看 | 天堂热 | 涩涩色中文综合亚洲 | 日韩在线免费看网站 | 久久国产精品一区 | 天天操天天摸天天舔 | 亚洲欧美一区在线 | 狠狠久久 | 美女网站在线观看视频18 | 午夜资源 | 在线精品日韩 | 国产精品视频免费一区二区三区 | 亚洲高清中文字幕一区二区三区 | 欧美精品99毛片免费高清观看 | 亚洲视频在线看 | 久草中文字 | 草草浮力影视 | 国产一二三区精品 | 天天操天天插天天干 | 亚洲第一黄色网址 | 日本狠狠干| 欧美电影精品久久久久 | 久久99国产亚洲精品观看 | 久久色亚洲 | 日本在线视频网 | 久久在线中文字幕 | 色综合中文字幕天天在线 | 成人国产精品 | 日本不卡一区二区 | 国产精品爱啪在线线免费观看 | 五月婷婷综合激情网 | 中文字幕日韩一区二区 | 亚洲精品专区 | 日韩在线不卡一区 | 羞羞视频网站在线观看 | 99热国产精品 |