python線程信號(hào)量semaphore怎么用

這篇文章主要介紹了python線程信號(hào)量semaphore怎么用，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

一.semaphore信號(hào)量原理

多線程同時(shí)運(yùn)行，能提高程序的運(yùn)行效率，但是并非線程越多越好，而semaphore信號(hào)量可以通過(guò)內(nèi)置計(jì)數(shù)器來(lái)控制同時(shí)運(yùn)行線程的數(shù)量，啟動(dòng)線程(消耗信號(hào)量)內(nèi)置計(jì)數(shù)器會(huì)自動(dòng)減一，線程結(jié)束(釋放信號(hào)量)內(nèi)置計(jì)數(shù)器會(huì)自動(dòng)加一；內(nèi)置計(jì)數(shù)器為零，啟動(dòng)線程會(huì)阻塞，直到有本線程結(jié)束或者其他線程結(jié)束為止;

二.semaphore信號(hào)量相關(guān)函數(shù)介紹

acquire() — 消耗信號(hào)量，內(nèi)置計(jì)數(shù)器減一;

release() — 釋放信號(hào)量，內(nèi)置計(jì)數(shù)器加一;

在semaphore信號(hào)量有一個(gè)內(nèi)置計(jì)數(shù)器，控制線程的數(shù)量，acquire()會(huì)消耗信號(hào)量，計(jì)數(shù)器會(huì)自動(dòng)減一；release()會(huì)釋放信號(hào)量，計(jì)數(shù)器會(huì)自動(dòng)加一；當(dāng)計(jì)數(shù)器為零時(shí)，acquire()調(diào)用被阻塞，直到release()釋放信號(hào)量為止。

三.semaphore信號(hào)量使用

創(chuàng)建多個(gè)線程，限制同一時(shí)間最多運(yùn)行5個(gè)線程，示例代碼如下：

# !usr/bin/env python
# -*- coding:utf-8 _*-
"""
@Author:何以解憂
@Blog(個(gè)人博客地址): shuopython.com
@WeChat Official Account(微信公眾號(hào))：猿說(shuō)python
@Github:www.github.com
 
@File:python_semaphore.py
@Time:2019/10/23 21:25
 
@Motto:不積跬步無(wú)以至千里，不積小流無(wú)以成江海，程序人生的精彩需要堅(jiān)持不懈地積累！
"""
 
# 導(dǎo)入線程模塊
import threading
# 導(dǎo)入時(shí)間模塊
import time
 
# 添加一個(gè)計(jì)數(shù)器，最大并發(fā)線程數(shù)量5(最多同時(shí)運(yùn)行5個(gè)線程)
semaphore = threading.Semaphore(5)
 
def foo():
  semaphore.acquire()  #計(jì)數(shù)器獲得鎖
  time.sleep(2)  #程序休眠2秒
  print("當(dāng)前時(shí)間：",time.ctime()) # 打印當(dāng)前系統(tǒng)時(shí)間
  semaphore.release()  #計(jì)數(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() #啟動(dòng)線程
 
  for t in thread_list:
    t.join()
 
  print("程序結(jié)束！")

輸出結(jié)果：

當(dāng)前時(shí)間： Wed Oct 23 22:21:59 2019
當(dāng)前時(shí)間： Wed Oct 23 22:21:59 2019
當(dāng)前時(shí)間： Wed Oct 23 22:21:59 2019
當(dāng)前時(shí)間： Wed Oct 23 22:21:59 2019
當(dāng)前時(shí)間： Wed Oct 23 22:21:59 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:01 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:01 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:01 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:01 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:01 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:03 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:03 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:03 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:03 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:03 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:05 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:05 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:05 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:05 2019
當(dāng)前時(shí)間： Wed Oct 23 22:22:05 2019
程序結(jié)束！

根據(jù)打印的日志可以看出，同一時(shí)間只有5個(gè)線程運(yùn)行，間隔兩秒之后，再次啟動(dòng)5個(gè)線程，直到20個(gè)線程全部運(yùn)行結(jié)束為止；如果沒(méi)有設(shè)置信號(hào)量Semapaore,創(chuàng)建線程直接start()，輸出的時(shí)間全部都是一樣的，這個(gè)問(wèn)題比較簡(jiǎn)單，可以自己去實(shí)驗(yàn)一下！

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“python線程信號(hào)量semaphore怎么用”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來(lái)學(xué)習(xí)!