Explication détaillée sur l'utilisation des sémaphores dans les threads Python3.X

Le sémaphore est une variable qui contrôle l'accès aux ressources publiques ou aux sections critiques. Le sémaphore maintient un compteur qui spécifie le nombre de threads pouvant accéder simultanément à la ressource ou entrer dans la section critique. L'article suivant vous présente principalement l'utilisation des sémaphores dans les threads Python3.X. Les amis dans le besoin peuvent s'y référer.

Préface

J'ai récemment appris Python et j'ai découvert que comprendre les connaissances de base des sémaphores de thread serait d'une grande aide pour comprendre les threads Python en profondeur. Cet article va donc vous présenter comment utiliser les sémaphores en Python3. >

Dans les threads, les sémaphores sont principalement utilisés pour maintenir des ressources limitées, de sorte que seul un nombre spécifié de threads puisse utiliser la ressource à un moment donné.

On constate que dans ce programme, seuls 2 robots sont toujours actifs

# -*- coding:utf-8 -*-
""" Created by FizLin on 2017/07/23/-下午10:59
 mail: https://github.com/Fiz1994
 信号量

 maxconnections = 5
...
pool_sema = BoundedSemaphore(value=maxconnections)
Once spawned, worker threads call the semaphore's acquire and release methods when they need to connect to the server:

pool_sema.acquire()
conn = connectdb()
... use connection ...
conn.close()
pool_sema.release()


"""
import threading
import time
import random

sites = ["https://www.baidu.com/", "https://github.com/Fiz1994", "https://stackoverflow.com/",
   "https://www.sogou.com/",
   "http://english.sogou.com/?b_o_e=1&ie=utf8&fr=common_index_nav&query="] * 20
sites_index = 0
maxconnections = 2
pool_sema = threading.BoundedSemaphore(value=maxconnections)


def test():
 with pool_sema:
  global sites_index, sites
  url = str(sites[sites_index])
  k = random.randint(10, 20)
  print("爬去： " + url + " 需要时间 : " + str(k))
  sites_index += 1
  # print(url)
  time.sleep(k)
  print('退出 ', url)


for i in range(100):
 threading.Thread(target=test).start()

Résumé

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!