Python 线程信号量 semaphore - Python零基础入门教程
目錄
- 一.Python 線程信號量 semaphore 簡介
- 二.Python 線程信號量 semaphore 原理
- 三.Python 線程信號量 semaphore 函數(shù)介紹
- 四.Python 線程信號量 semaphore 使用
- 五.猜你喜歡
零基礎(chǔ) Python 學(xué)習(xí)路線推薦 : Python 學(xué)習(xí)目錄 >> Python 基礎(chǔ)入門
一.Python 線程信號量 semaphore 簡介
通過前面對 線程互斥鎖 lock / 線程事件 event / 線程條件變量 condition / 線程定時器 timer 的講解,相信你對線程 threading 模塊已經(jīng)有了一定的了解,同時執(zhí)行多個線程的確可以提高程序的效率,但是并非線程的數(shù)量越多越好,可能對于計算機而言,你直接運行 20 ~ 30 線程可能沒太大影響,如果同時運行上千個甚至上萬個呢?我相信你電腦會直接癱瘓……
二.Python 線程信號量 semaphore 原理
多線程同時運行,能提高程序的運行效率,但是并非線程越多越好,而 semaphore 信號量可以通過內(nèi)置計數(shù)器來控制同時運行線程的數(shù)量,啟動線程**(消耗信號量)內(nèi)置計數(shù)器會自動減一,線程結(jié)束(釋放信號量)**內(nèi)置計數(shù)器會自動加一;內(nèi)置計數(shù)器為零,啟動線程會阻塞,直到有本線程結(jié)束或者其他線程結(jié)束為止;
三.Python 線程信號量 semaphore 函數(shù)介紹
- **acquire **— 消耗信號量,內(nèi)置計數(shù)器減一;
- **release **— 釋放信號量,內(nèi)置計數(shù)器加一;
在 semaphore 信號量有一個內(nèi)置計數(shù)器,控制線程的數(shù)量,acquire 會消耗信號量,計數(shù)器會自動減一;release 會釋放信號量,計數(shù)器會自動加一;當(dāng)計數(shù)器為零時,acquire 調(diào)用被阻塞,直到 release 釋放信號量為止。
四.Python 線程信號量 semaphore 使用
創(chuàng)建多個線程,限制同一時間最多運行 5 個線程,示例代碼如下:
# !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:猿說編程 @Blog(個人博客地址): www.codersrc.com @File:Python 線程信號量 semaphore.py @Time:2021/05/04 07:37 @Motto:不積跬步無以至千里,不積小流無以成江海,程序人生的精彩需要堅持不懈地積累!"""# 導(dǎo)入線程模塊 import threading # 導(dǎo)入時間模塊 import time# 添加一個計數(shù)器,最大并發(fā)線程數(shù)量5(最多同時運行5個線程) semaphore = threading.Semaphore(5)def foo():semaphore.acquire() #計數(shù)器獲得鎖time.sleep(2) #程序休眠2秒print("當(dāng)前時間:",time.ctime()) # 打印當(dāng)前系統(tǒng)時間semaphore.release() #計數(shù)器釋放鎖if __name__ == "__main__":thread_list= list()for i in range(20):t=threading.Thread(target=foo,args=()) #創(chuàng)建線程thread_list.append(t)t.start() #啟動線程for t in thread_list:t.join()print("程序結(jié)束!")''' 輸出結(jié)果:當(dāng)前時間: Tue May 4 12:01:43 2021 當(dāng)前時間: Tue May 4 12:01:43 2021 當(dāng)前時間: Tue May 4 12:01:43 2021 當(dāng)前時間: Tue May 4 12:01:43 2021 當(dāng)前時間: Tue May 4 12:01:43 2021 當(dāng)前時間: Tue May 4 12:01:45 2021 當(dāng)前時間: Tue May 4 12:01:45 2021 當(dāng)前時間: Tue May 4 12:01:45 2021 當(dāng)前時間: Tue May 4 12:01:45 2021 當(dāng)前時間: Tue May 4 12:01:45 2021 當(dāng)前時間: Tue May 4 12:01:47 2021 當(dāng)前時間: Tue May 4 12:01:47 2021 當(dāng)前時間: Tue May 4 12:01:47 2021 當(dāng)前時間: Tue May 4 12:01:47 2021 當(dāng)前時間: Tue May 4 12:01:47 2021 當(dāng)前時間: Tue May 4 12:01:49 2021 當(dāng)前時間: Tue May 4 12:01:49 2021 當(dāng)前時間: Tue May 4 12:01:49 2021 當(dāng)前時間: Tue May 4 12:01:49 2021 當(dāng)前時間: Tue May 4 12:01:49 2021 程序結(jié)束!Process finished with exit code 0'''根據(jù)打印的日志可以看出,同一時間只有 5 個線程運行,間隔兩秒之后,再次啟動 5 個線程,直到 20 個線程全部運行結(jié)束為止;如果沒有設(shè)置信號量 Semapaore ,創(chuàng)建線程直接 start ,輸出的時間全部都是一樣的,這個問題比較簡單,可以自己去實驗一下!
五.猜你喜歡
未經(jīng)允許不得轉(zhuǎn)載:猿說編程 ? Python 線程信號量 semaphore
創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯,堅持創(chuàng)作打卡瓜分現(xiàn)金大獎總結(jié)
以上是生活随笔為你收集整理的Python 线程信号量 semaphore - Python零基础入门教程的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: BugkuCTF-MISC题宽带信息泄露
- 下一篇: Python frozenset 集合