之前的文章中講解很多關(guān)于線程間通信的知識(shí)，比如：線程互斥鎖lock，線程事件event，線程條件變量condition?等等，這些都是在開發(fā)中經(jīng)常使用的內(nèi)容，而今天繼續(xù)給大家講解一個(gè)更重要的知識(shí)點(diǎn) —?線程隊(duì)列queue。
1.線程隊(duì)列Queue?— FIFO(先進(jìn)先出隊(duì)列)，即哪個(gè)數(shù)據(jù)先存入，取數(shù)據(jù)的時(shí)候先取哪個(gè)數(shù)據(jù)，同生活中的排隊(duì)買東西；
2.線程隊(duì)列LifoQueue?— LIFO(先進(jìn)后出隊(duì)列)，即哪個(gè)數(shù)據(jù)最后存入的，取數(shù)據(jù)的時(shí)候先??；
3.線程隊(duì)列PriorityQueue?— PriorityQueue(優(yōu)先級(jí)隊(duì)列)，即存入數(shù)據(jù)時(shí)候加入一個(gè)優(yōu)先級(jí)，取數(shù)據(jù)的時(shí)候優(yōu)先級(jí)高的取出；
今天只對(duì)第一種普通線程隊(duì)列Queue(FIFO)講解，后面的兩種留到下一篇文章在做詳細(xì)講解！
線程隊(duì)列Queue，也稱FIFO，存在隊(duì)列中的數(shù)據(jù)先進(jìn)先出，就好比拉肚子，吃什么拉什么～～呃呃，有點(diǎn)重口味，如下圖：
舉個(gè)形象的例子：如果把123456這6個(gè)數(shù)字，依次放入隊(duì)列queue中，那么我們重隊(duì)列中取數(shù)據(jù)的時(shí)候，取到的第一個(gè)數(shù)據(jù)必然是1，第二個(gè)數(shù)據(jù)必然是2，依次類推，這就是所謂的吃什么拉什么 — FIFO(先進(jìn)先出)
Queue.qsize() ? 返回隊(duì)列大小
Queue.empty() 判斷隊(duì)列是否為空
Queue.full() ? ? ? 判斷隊(duì)列是否滿了
Queue.get([block[,timeout]]) 從隊(duì)列頭刪除并返回一個(gè)item，block默認(rèn)為True，表示當(dāng)隊(duì)列為空卻去get的時(shí)候會(huì)阻塞線程，等待直到有有item出現(xiàn)為止來get出這個(gè)item。如果是False的話表明當(dāng)隊(duì)列為空你卻去get的時(shí)候，會(huì)引發(fā)異常。在block為True的情況下可以再設(shè)置timeout參數(shù)。表示當(dāng)隊(duì)列為空，get阻塞timeout指定的秒數(shù)之后還沒有g(shù)et到的話就引發(fā)Full異常。
Queue.task_done() 從場(chǎng)景上來說，處理完一個(gè)get出來的item之后，調(diào)用task_done將向隊(duì)列發(fā)出一個(gè)信號(hào)，表示本任務(wù)已經(jīng)完成(與Queue.get配對(duì)使用)。
Queue.put(…[,block[,timeout]]) 向隊(duì)尾插入一個(gè)item，同樣若block=True的話隊(duì)列滿時(shí)就阻塞等待有空位出來再put，block=False時(shí)引發(fā)異常。同get的timeout，put的timeout是在block為True的時(shí)候進(jìn)行超時(shí)設(shè)置的參數(shù)。
Queue.join() 監(jiān)視所有item并阻塞主線程，直到所有item都調(diào)用了task_done之后主線程才繼續(xù)向下執(zhí)行。這么做的好處在于，假如一個(gè)線程開始處理最后一個(gè)任務(wù)，它從任務(wù)隊(duì)列中拿走最后一個(gè)任務(wù)，此時(shí)任務(wù)隊(duì)列就空了但最后那個(gè)線程還沒處理完。當(dāng)調(diào)用了join之后，主線程就不會(huì)因?yàn)殛?duì)列空了而擅自結(jié)束，而是等待最后那個(gè)線程處理完成了。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | # !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:何以解憂 @Blog(個(gè)人博客地址): shuopython.com @WeChat Official Account(微信公眾號(hào))：猿說python @Github:www.github.com @File:python_queue.py @Time:2019/11/29 15:25 @Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅(jiān)持不懈地積累！ """ importthreading importqueue q=queue.Queue(5)??# 長(zhǎng)度，隊(duì)列中最多存放5個(gè)數(shù)據(jù) defput(): foriinrange(20): q.put(i) print("數(shù)字%d存入隊(duì)列成功"%i) q.join()??# 阻塞進(jìn)程，直到所有任務(wù)完成，取多少次數(shù)據(jù)task_done多少次才行，否則最后的ok無法打印 print('ok') defget(): foriinrange(20): value=q.get() print("數(shù)字%d重隊(duì)列中取出"%value) q.task_done()??# 必須每取走一個(gè)數(shù)據(jù)，發(fā)一個(gè)信號(hào)給join # q.task_done()?? #放在這沒用，因?yàn)閖oin實(shí)際上是一個(gè)計(jì)數(shù)器，put了多少個(gè)數(shù)據(jù)， # 計(jì)數(shù)器就是多少，每task_done一次，計(jì)數(shù)器減1，直到為0才繼續(xù)執(zhí)行 t1=threading.Thread(target=put,args=()) t1.start() t2=threading.Thread(target=get,args=()) t2.start() |
輸出結(jié)果：
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | 數(shù)字0存入隊(duì)列成功 數(shù)字1存入隊(duì)列成功 數(shù)字2存入隊(duì)列成功 數(shù)字3存入隊(duì)列成功 數(shù)字4存入隊(duì)列成功 數(shù)字0重隊(duì)列中取出 數(shù)字1重隊(duì)列中取出 數(shù)字2重隊(duì)列中取出 數(shù)字3重隊(duì)列中取出 數(shù)字4重隊(duì)列中取出 數(shù)字5存入隊(duì)列成功 數(shù)字6存入隊(duì)列成功 數(shù)字7存入隊(duì)列成功 數(shù)字8存入隊(duì)列成功 數(shù)字9存入隊(duì)列成功 數(shù)字5重隊(duì)列中取出 數(shù)字6重隊(duì)列中取出 數(shù)字7重隊(duì)列中取出 數(shù)字8重隊(duì)列中取出 數(shù)字9重隊(duì)列中取出 數(shù)字10存入隊(duì)列成功 數(shù)字11存入隊(duì)列成功 數(shù)字12存入隊(duì)列成功 數(shù)字13存入隊(duì)列成功 數(shù)字14存入隊(duì)列成功 數(shù)字10重隊(duì)列中取出 數(shù)字11重隊(duì)列中取出 數(shù)字12重隊(duì)列中取出 數(shù)字15存入隊(duì)列成功 數(shù)字16存入隊(duì)列成功 數(shù)字17存入隊(duì)列成功 數(shù)字13重隊(duì)列中取出 數(shù)字14重隊(duì)列中取出 數(shù)字15重隊(duì)列中取出 數(shù)字16重隊(duì)列中取出 數(shù)字18存入隊(duì)列成功 數(shù)字19存入隊(duì)列成功 數(shù)字17重隊(duì)列中取出 數(shù)字18重隊(duì)列中取出 數(shù)字19重隊(duì)列中取出 ok |
1.pycharm配置開發(fā)模板
2.python字典推導(dǎo)式
3.python列表推導(dǎo)式
4.python匿名函數(shù)lambda
轉(zhuǎn)載請(qǐng)注明：猿說Python???python線程隊(duì)列Queue-FIFO
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。
重慶分公司
重慶分公司
