在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Python  C  C++  Ruby  網(wǎng)絡(luò)安全/ Python 隊(duì)列Queue和管道Pipes是如何實(shí)現(xiàn)的?

Python 隊(duì)列Queue和管道Pipes是如何實(shí)現(xiàn)的?

問題1:

隊(duì)列和管道好像是基于文件的?
就是把信息發(fā)送到特定文件?再從文件中讀取?
如果是這樣,那么這個(gè)文件生成在哪個(gè)目錄?隱藏嗎?對(duì)用戶可見嗎?如果在linux下,對(duì)用戶權(quán)限如何?
如果不是基于文件,那么是如何實(shí)現(xiàn)?

問題2:

# 創(chuàng)建一個(gè)隊(duì)列
q = Queue()
# 阻塞模式下直接讀取會(huì)阻塞(因?yàn)闆]數(shù)據(jù)傳入隊(duì)列)
value = q.get()

阻塞表示程序知道我還得取得一個(gè)值,就等待一個(gè)值發(fā)送進(jìn)來,那么總要有個(gè)檢測(cè)間隔嘛?
這個(gè)檢測(cè)間隔是多少?多少秒?對(duì),就是時(shí)間是多少?

為什么問這個(gè)?
因?yàn)?如果自己寫的話:

while True:
    if flag == True:
        #do sonming #
        break

flag遲遲不變?yōu)門rue的話直接cpu就滿了,所以我一般寫如上代碼都會(huì)加一個(gè)time.sleep(n),讓程序中斷n秒后再檢測(cè)Flag的值

while True:
    if flag == True:
        #do sonming #
        break
    time.sleep(1)

這樣完全不用考慮消耗cpu的問題,因?yàn)?秒對(duì)于cpu來說"太長(zhǎng)"了
在線程中更簡(jiǎn)單的是,直接使用隊(duì)列,隊(duì)列傳入一個(gè)flag值進(jìn)來讓程序繼續(xù)運(yùn)行,完全不用while True:

# 
q = Quant()
# 定義線程函數(shù)
def thread_fun():
    # 要是沒有值進(jìn)來下面這句就無限阻塞
    q.get()
    # 當(dāng)有某個(gè)值q.put()時(shí)就會(huì)接著運(yùn)行
    #do sonming #

(不知道說的對(duì)不對(duì),不對(duì)請(qǐng)指出,下面這句)
我這久都是這么寫的,我覺得這樣可以很好的控制,最主要的是隊(duì)列和管道不用考慮鎖的問題,這樣寫不知道效率如何,還是我考慮多了
我猜測(cè)q.get()里的實(shí)現(xiàn)肯定有while True啊,那么他要不要控制檢測(cè)的頻率??

還是文件系統(tǒng)的檢測(cè)有什么不一樣?
因?yàn)槲疫€寫過一個(gè)一個(gè)進(jìn)程寫一個(gè)文件,一個(gè)進(jìn)程讀同一個(gè)文件的,讀的進(jìn)程讀到文件的末尾,可以接著readline,只是返回''(空字符串)就是了,這樣我肯定不能讓讀的進(jìn)程無限讀文件啊,消耗cpu和IO,后來我就加了time.sleep(0.5),我覺得對(duì)于人來看,0.5秒的間隔夠了

但是我比較貪心啊,想追求效率,就是q.get()如果內(nèi)部不用循環(huán)檢測(cè)的話,那么效率應(yīng)該會(huì)比較高,請(qǐng)問其實(shí)如何實(shí)現(xiàn)的?

想再開個(gè)問題問協(xié)程的,這個(gè)和協(xié)程有沒有關(guān)系?(還在學(xué)習(xí))
算了,不問了,以上
謝謝

回答
編輯回答
浪婳

1、隊(duì)列和管道如果你指的是multiprocessing,那多進(jìn)程之間通信是在內(nèi)存層面實(shí)現(xiàn)的
2、q.get() https://docs.python.org/3.6/l...
你沒有傳參數(shù),所以會(huì)一直等到隊(duì)列的下一個(gè)數(shù)據(jù)為止,你可以設(shè)置q.get(timeout=10) 10秒后拿不到數(shù)據(jù)就超時(shí)

2017年4月15日 06:47