久久精品国产亚洲高清|精品日韩中文乱码在线|亚洲va中文字幕无码久|伊人久久综合狼伊人久久|亚洲不卡av不卡一区二区|精品久久久久久久蜜臀AV|国产精品19久久久久久不卡|国产男女猛烈视频在线观看麻豆

    1. <style id="76ofp"></style>

      <style id="76ofp"></style>
      <rt id="76ofp"></rt>
      <form id="76ofp"><optgroup id="76ofp"></optgroup></form>
      1. 千鋒教育-做有情懷、有良心、有品質(zhì)的職業(yè)教育機(jī)構(gòu)

        手機(jī)站
        千鋒教育

        千鋒學(xué)習(xí)站 | 隨時(shí)隨地免費(fèi)學(xué)

        千鋒教育

        掃一掃進(jìn)入千鋒手機(jī)站

        領(lǐng)取全套視頻
        千鋒教育

        關(guān)注千鋒學(xué)習(xí)站小程序
        隨時(shí)隨地免費(fèi)學(xué)習(xí)課程

        當(dāng)前位置:首頁(yè)  >  技術(shù)干貨  > python隊(duì)列Queue

        python隊(duì)列Queue

        來(lái)源:千鋒教育
        發(fā)布人:xqq
        時(shí)間: 2023-11-07 08:24:21 1699316661

        Queue

        Queue是python標(biāo)準(zhǔn)庫(kù)中的線程安全的隊(duì)列(FIFO)實(shí)現(xiàn),提供了一個(gè)適用于多線程編程的先進(jìn)先出的數(shù)據(jù)結(jié)構(gòu),即隊(duì)列,用來(lái)在生產(chǎn)者和消費(fèi)者線程之間的信息傳遞

        基本FIFO隊(duì)列

        classQueue.Queue(maxsize=0)

        FIFO即FirstinFirstOut,先進(jìn)先出。Queue提供了一個(gè)基本的FIFO容器,使用方法很簡(jiǎn)單,maxsize是個(gè)整數(shù),指明了隊(duì)列中能存放的數(shù)據(jù)個(gè)數(shù)的上限。一旦達(dá)到上限,插入會(huì)導(dǎo)致阻塞,直到隊(duì)列中的數(shù)據(jù)被消費(fèi)掉。如果maxsize小于或者等于0,隊(duì)列大小沒(méi)有限制。

        舉個(gè)栗子:

        importQueue

        q=Queue.Queue()

        foriinrange(5):

        q.put(i)

        whilenotq.empty():

        printq.get()

        輸出:

        0

        1

        2

        3

        4

        LIFO隊(duì)列

        classQueue.LifoQueue(maxsize=0)

        LIFO即LastinFirstOut,后進(jìn)先出。與棧的類(lèi)似,使用也很簡(jiǎn)單,maxsize用法同上

        再舉個(gè)栗子:

        importQueue

        q=Queue.LifoQueue()

        foriinrange(5):

        q.put(i)

        whilenotq.empty():

        printq.get()

        輸出:

        4

        3

        2

        1

        0

        可以看到僅僅是將Queue.Quenu類(lèi)替換為Queue.LifiQueue類(lèi)

        優(yōu)先級(jí)隊(duì)列

        classQueue.PriorityQueue(maxsize=0)

        構(gòu)造一個(gè)優(yōu)先隊(duì)列。maxsize用法同上。

        importQueue

        importthreading

        classJob(object):

        def__init__(self,priority,description):

        self.priority=priority

        self.description=description

        print'Job:',description

        return

        def__cmp__(self,other):

        returncmp(self.priority,other.priority)

        q=Queue.PriorityQueue()

        q.put(Job(3,'level3job'))

        q.put(Job(10,'level10job'))

        q.put(Job(1,'level1job'))

        defprocess_job(q):

        whileTrue:

        next_job=q.get()

        print'for:',next_job.description

        q.task_done()

        workers=[threading.Thread(target=process_job,args=(q,)),

        threading.Thread(target=process_job,args=(q,))

        ]

        forwinworkers:

        w.setDaemon(True)

        w.start()

        q.join()

        結(jié)果

        Job:level3job

        Job:level10job

        Job:level1job

        for:level1job

        for:level3job

        for:job:level10job

        一些常用方法

        task_done()

        意味著之前入隊(duì)的一個(gè)任務(wù)已經(jīng)完成。由隊(duì)列的消費(fèi)者線程調(diào)用。每一個(gè)get()調(diào)用得到一個(gè)任務(wù),接下來(lái)的task_done()調(diào)用告訴隊(duì)列該任務(wù)已經(jīng)處理完畢。

        如果當(dāng)前一個(gè)join()正在阻塞,它將在隊(duì)列中的所有任務(wù)都處理完時(shí)恢復(fù)執(zhí)行(即每一個(gè)由put()調(diào)用入隊(duì)的任務(wù)都有一個(gè)對(duì)應(yīng)的task_done()調(diào)用)。

        join()

        阻塞調(diào)用線程,直到隊(duì)列中的所有任務(wù)被處理掉。

        只要有數(shù)據(jù)被加入隊(duì)列,未完成的任務(wù)數(shù)就會(huì)增加。當(dāng)消費(fèi)者線程調(diào)用task_done()(意味著有消費(fèi)者取得任務(wù)并完成任務(wù)),未完成的任務(wù)數(shù)就會(huì)減少。當(dāng)未完成的任務(wù)數(shù)降到0,join()解除阻塞。

        put(item[,block[,timeout]])

        將item放入隊(duì)列中。

        如果可選的參數(shù)block為T(mén)rue且timeout為空對(duì)象(默認(rèn)的情況,阻塞調(diào)用,無(wú)超時(shí))。

        如果timeout是個(gè)正整數(shù),阻塞調(diào)用進(jìn)程最多timeout秒,如果一直無(wú)空空間可用,拋出Full異常(帶超時(shí)的阻塞調(diào)用)。

        如果block為False,如果有空閑空間可用將數(shù)據(jù)放入隊(duì)列,否則立即拋出Full異常

        其非阻塞版本為put_nowait等同于put(item,False)

        get([block[,timeout]])

        從隊(duì)列中移除并返回一個(gè)數(shù)據(jù)。block跟timeout參數(shù)同put方法

        其非阻塞方法為get_nowait()相當(dāng)與get(False)

        empty()

        如果隊(duì)列為空,返回True,反之返回False

        以上內(nèi)容為大家介紹了python隊(duì)列Queue,希望對(duì)大家有所幫助,如果想要了解更多Python相關(guān)知識(shí),請(qǐng)關(guān)注IT培訓(xùn)機(jī)構(gòu):千鋒教育。http://m.2667701.com/

        聲明:本站稿件版權(quán)均屬千鋒教育所有,未經(jīng)許可不得擅自轉(zhuǎn)載。
        10年以上業(yè)內(nèi)強(qiáng)師集結(jié),手把手帶你蛻變精英
        請(qǐng)您保持通訊暢通,專(zhuān)屬學(xué)習(xí)老師24小時(shí)內(nèi)將與您1V1溝通
        免費(fèi)領(lǐng)取
        今日已有369人領(lǐng)取成功
        劉同學(xué) 138****2860 剛剛成功領(lǐng)取
        王同學(xué) 131****2015 剛剛成功領(lǐng)取
        張同學(xué) 133****4652 剛剛成功領(lǐng)取
        李同學(xué) 135****8607 剛剛成功領(lǐng)取
        楊同學(xué) 132****5667 剛剛成功領(lǐng)取
        岳同學(xué) 134****6652 剛剛成功領(lǐng)取
        梁同學(xué) 157****2950 剛剛成功領(lǐng)取
        劉同學(xué) 189****1015 剛剛成功領(lǐng)取
        張同學(xué) 155****4678 剛剛成功領(lǐng)取
        鄒同學(xué) 139****2907 剛剛成功領(lǐng)取
        董同學(xué) 138****2867 剛剛成功領(lǐng)取
        周同學(xué) 136****3602 剛剛成功領(lǐng)取
        相關(guān)推薦HOT
        Python變量簡(jiǎn)介

        1.Python變量的賦值在編程語(yǔ)言中,將數(shù)據(jù)放入變量的過(guò)程叫做賦值(Assignment)。每個(gè)變量在使用前都必須賦值,變量賦值以后,該變量才會(huì)被創(chuàng)建。...詳情>>

        2023-11-07 10:59:09
        Python2.x中的編碼問(wèn)題

        1.str和unicodestr和unicode都是basestring的子類(lèi)。嚴(yán)格意義上說(shuō),str其實(shí)是字節(jié)串,它是unicode經(jīng)過(guò)編碼后的字節(jié)組成的序列。對(duì)UTF-8編碼的str...詳情>>

        2023-11-07 10:44:45
        Python對(duì)象的創(chuàng)建

        python會(huì)用兩種方法創(chuàng)建對(duì)象,一種是泛型API(AOL:AbstractObjectLayer),可以應(yīng)用在任何Python對(duì)象上,API內(nèi)不會(huì)有機(jī)制確定最終調(diào)用哪個(gè)具體函...詳情>>

        2023-11-07 10:33:57
        Python的元組

        什么是python元組?java中可沒(méi)有聽(tīng)過(guò)內(nèi)置元組這樣的數(shù)據(jù)結(jié)構(gòu)。在前面已經(jīng)講了列表,知道一個(gè)列表可以存儲(chǔ)多個(gè)數(shù)據(jù)結(jié)構(gòu)。元組和列表很像,但要記...詳情>>

        2023-11-07 10:26:45
        python單元測(cè)試框架unittest

        unittest是python單元測(cè)試框架,又叫做PyUnit。之所以稱(chēng)為框架是它代替開(kāi)發(fā)人員完成了一些調(diào)用、IO等與單元測(cè)試無(wú)直接關(guān)系的支撐代碼,讓開(kāi)發(fā)人...詳情>>

        2023-11-07 09:57:57
        尼勒克县| 桂林市| 荣成市| 沁水县| 新田县| 连平县| 伊春市| 祁东县| 香河县| 霍林郭勒市| 英吉沙县| 大石桥市| 定结县| 中阳县| 叶城县| 石门县| 宝清县| 大埔区| 博兴县| 呼伦贝尔市| 元氏县| 大丰市| 木里| 朝阳县| 淮阳县| 夹江县| 靖州| 陇川县| 鞍山市| 新宁县| 汪清县| 泸水县| 正镶白旗| 舒兰市| 聊城市| 广西| 长泰县| 永嘉县| 南康市| 逊克县| 辽阳县|