Exemples de code d'opérations de producteur et de consommateur d'objets Python Condition

Cet article présente principalement les opérations de producteur et de consommateur des variables de condition Python et analyse les concepts, les principes et les techniques liées au fonctionnement des threads des variables de condition Python sous la forme d'exemples spécifiques. Les amis dans le besoin peuvent s'y référer

.

L'exemple de cet article décrit les opérations de producteur et de consommateur des variables de condition Python. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

Le verrouillage Mutex est le mécanisme de synchronisation de thread le plus simple. Pour faire face à des problèmes complexes de synchronisation de thread, Python fournit également l'objet Condition . La condition est appelée variable de condition. En plus de fournir des méthodes d'acquisition et de libération similaires à Lock, elle fournit également des méthodes d'attente et de notification. Le thread acquiert d’abord une variable de condition, puis détermine certaines conditions. Si les conditions ne sont pas remplies, attendez ; si les conditions sont remplies, effectuez un traitement pour modifier les conditions et informez les autres threads via la méthode de notification. Les autres threads dans l'état d'attente réévalueront les conditions. après avoir reçu la notification. Ce processus est répété en continu pour résoudre des problèmes de synchronisation complexes.

On peut penser que l'objet Condition maintient un verrou (Lock/RLock) et un pool d'attente. Le thread obtient l'objet Condition via l'acquisition. Lorsque la méthode wait est appelée, le thread libère le verrou à l'intérieur de la Condition et entre dans l'état bloqué (mais il ne bloque pas réellement le thread actuel) et enregistre ce thread dans le pool d'attente. Lorsque la méthode notify est appelée, l'objet Condition sélectionnera un thread dans le pool d'attente et lui demandera d'appeler la méthode d'acquisition pour tenter d'acquérir le verrou. Le

Constructeur de l'objet

Condition peut accepter un objet Lock/RLock comme paramètre S'il n'est pas spécifié, l'objet Condition créera un RLock en interne.

Le problème classique de la synchronisation des threads : le problème du producteur et du consommateur peut être facilement résolu à l'aide de variables de condition.

import threading
import time
class Producer(threading.Thread):
  def init(self):
    threading.Thread.init(self)
  def run(self):
    global count
    while True:
      con.acquire()
      if count <20:
        count += 1
        print self.name," Producer product 1,current is %d" %(count)
        con.notify()
      else:
        print self.name,"Producer say box is full"
        con.wait()
      con.release()
      time.sleep(1)
class Consumer(threading.Thread):
  def init(self):
    threading.Thread.init(self)
  def run(self):
    global count
    while True:
      con.acquire()
      if count>4:
        count -=4
        print self.name,"Consumer consume 4,current is %d" %(count)
        con.notify()
      else:
        con.wait()
        print self.name," Consumer say box is empty"
      con.release()
      time.sleep(1)
count = 0
con = threading.Condition()
def test():
  for i in range(1):
    a = Consumer()
    a.start()
  for i in range(1):
    b =Producer()
    b.start()
if name==&#39;main&#39;:
  test()

Le code ci-dessus suppose que les consommateurs consomment rapidement, et le résultat est :

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!