python線程信號量semaphore使用解析

更新時間：2019年11月30日 16:07:31 作者：猿說python

這篇文章主要介紹了python線程信號量semaphore使用解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

一.semaphore信號量原理

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

二.semaphore信號量相關函數(shù)介紹

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

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

在semaphore信號量有一個內(nèi)置計數(shù)器，控制線程的數(shù)量，acquire()會消耗信號量，計數(shù)器會自動減一；release()會釋放信號量，計數(shù)器會自動加一；當計數(shù)器為零時，acquire()調用被阻塞，直到release()釋放信號量為止。

三.semaphore信號量使用

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

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

輸出結果：

當前時間： Wed Oct 23 22:21:59 2019
當前時間： Wed Oct 23 22:21:59 2019
當前時間： Wed Oct 23 22:21:59 2019
當前時間： Wed Oct 23 22:21:59 2019
當前時間： Wed Oct 23 22:21:59 2019
當前時間： Wed Oct 23 22:22:01 2019
當前時間： Wed Oct 23 22:22:01 2019
當前時間： Wed Oct 23 22:22:01 2019
當前時間： Wed Oct 23 22:22:01 2019
當前時間： Wed Oct 23 22:22:01 2019
當前時間： Wed Oct 23 22:22:03 2019
當前時間： Wed Oct 23 22:22:03 2019
當前時間： Wed Oct 23 22:22:03 2019
當前時間： Wed Oct 23 22:22:03 2019
當前時間： Wed Oct 23 22:22:03 2019
當前時間： Wed Oct 23 22:22:05 2019
當前時間： Wed Oct 23 22:22:05 2019
當前時間： Wed Oct 23 22:22:05 2019
當前時間： Wed Oct 23 22:22:05 2019
當前時間： Wed Oct 23 22:22:05 2019
程序結束！

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

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: