之前的文章中講解很多關(guān)于線程間通信的知識，比如：線程互斥鎖lock，線程事件event，線程條件變量condition?等等，這些都是在開發(fā)中經(jīng)常使用的內(nèi)容，而今天繼續(xù)給大家講解一個(gè)更重要的知識點(diǎn) —?線程隊(duì)列queue。

10年積累的成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、外貿(mào)網(wǎng)站建設(shè)經(jīng)驗(yàn)，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識你，你也不認(rèn)識我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有臨江免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

一.隊(duì)列分類：

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)先級隊(duì)列)，即存入數(shù)據(jù)時(shí)候加入一個(gè)優(yōu)先級，取數(shù)據(jù)的時(shí)候優(yōu)先級最高的取出；

今天只對第一種普通線程隊(duì)列Queue(FIFO)講解，后面的兩種留到下一篇文章在做詳細(xì)講解！

?

?

二.先進(jìn)先出隊(duì)列Queue簡介

線程隊(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)先出)

?

三.先進(jìn)先出隊(duì)列Queue常用函數(shù)

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í)候會阻塞線程，等待直到有有item出現(xiàn)為止來get出這個(gè)item。如果是False的話表明當(dāng)隊(duì)列為空你卻去get的時(shí)候，會引發(fā)異常。在block為True的情況下可以再設(shè)置timeout參數(shù)。表示當(dāng)隊(duì)列為空，get阻塞timeout指定的秒數(shù)之后還沒有g(shù)et到的話就引發(fā)Full異常。

?

Queue.task_done()　　從場景上來說，處理完一個(gè)get出來的item之后，調(diào)用task_done將向隊(duì)列發(fā)出一個(gè)信號，表示本任務(wù)已經(jīng)完成(與Queue.get配對使用)。

?

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之后，主線程就不會因?yàn)殛?duì)列空了而擅自結(jié)束，而是等待最后那個(gè)線程處理完成了。

?

?

四.先進(jìn)先出隊(duì)列Queue使用：

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(微信公眾號)：猿說python @Github:www.github.com ? @File:python_queue.py @Time:2019/11/29 15:25 ? @Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅(jiān)持不懈地積累！ """ ? importthreading importqueue ? q=queue.Queue(5)??# 長度，隊(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è)信號給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)載請注明：猿說Python???python線程隊(duì)列Queue-FIFO

?

本文名稱：35.python線程隊(duì)列Queue-FIFO
當(dāng)前地址：http://chinadenli.net/article46/jggphg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設(shè)、服務(wù)器托管、微信小程序、用戶體驗(yàn)、網(wǎng)站設(shè)計(jì)公司、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)