Fil des variables de condition: onu-verrou acquis

J'ai cet exemple en Python qui illustre l'utilisation de variables de condition.

import logging
import threading
import time

logging.basicConfig(level=logging.DEBUG, format='%(asctime)s (%(threadName)-2s) %(message)s',)

def consumer(cond):

    # wait for the condition and use the resource

    logging.debug('Starting consumer thread')

    t = threading.currentThread()

    cond.wait()

    logging.debug('Resource is available to consumer')

def producer(cond):

    # set up the resource to be used by the consumer

    logging.debug('Starting producer thread')

    logging.debug('Making resource available')

    cond.notifyAll()


condition = threading.Condition()

# pass each thread a 'condition'
c1 = threading.Thread(name='c1', target=consumer, args=(condition,))
c2 = threading.Thread(name='c2', target=consumer, args=(condition,))
p = threading.Thread(name='p', target=producer, args=(condition,))


# start two threads and put them into 'wait' state
c1.start()
c2.start()

# after two seconds or after some operation notify them to free or step over the wait() function
time.sleep(2)
p.start()

Cependant, il génère une erreur d'exécution un-acquired lock sur les threads. J'ai une idée que j'ai besoin d'utiliser acquire et release fonctions mais je ne suis pas sûr au sujet de leur utilisation et de ce que exactement ce qu'ils font.

Où est la condition? Lorsque le consommateur appelle wait -- où est la chose qu'il attend? Lorsque le produit des appels notify, où est la chose, c'est informer les personnes au sujet? Vous ne pouvez pas utiliser une variable de condition, à moins que vous avez une condition (appelé un "prédicat").

OriginalL'auteur cpx | 2014-04-16

9

Conditions sont un wrapper autour d'un sous-jacent Lock qui fournissent wait/notify fonctionnalité. Vous devez acquire un verrou avant de le libérer - qui wait n'sous le capot. Notamment une fois qu'il se re-réveillé, il rachète la serrure. Ainsi, l'exclusion mutuelle est assurée entre l'acquisition et au relâchement, avec wait "rendement" de contrôle de la serrure, si cela fait sens.

Au lieu de faire l'acquisition/déverrouiller manuellement, il suffit d'utiliser la Condition comme un gestionnaire de contexte:
```
def consumer(cond):
    with cond:
        cond.wait()

    logging.debug('Resource is available to consumer')
```
Si, pour quelque raison que ce soit, vous êtes coincé sur une version de python sans contexte les gestionnaires, ce qui est équivalent à:
```
def consumer(cond):
    try:
        cond.acquire()
        cond.wait()
    finally:
        cond.release()

    logging.debug('Resource is available to consumer')
```
Souvent que vous le souhaitez afin de s'assurer que seulement un consommateur obtient réveillé, de sorte que la marche suivante est fréquemment utilisé:
```
with cond:
    while some_queue.isEmpty():
        cond.wait()
    #get one from queue
```
Ainsi, vous pouvez vous notify importe quel nombre de consommateurs et la plus juste aller immédiatement en arrière de dormir une fois la File d'attente est vide.

Dans Python 2.5 car il n'est pas with déclaration, aurais-je mettre acquire et release autour de la wait fonction?
Vous avez besoin d'envelopper les choses avec try/finally pour obtenir la même sémantique que d'un gestionnaire de contexte, voir modifier.
Qu'est-ce verrou faire et pourquoi avez-vous besoin?
Un Lock assure qu'un seul thread peut entrer dans un bloc de code à un moment donné - aka exclusion mutuelle. Vous avez "besoin" seulement dans la mesure où c'est la façon dont Condition fonctionne, je ne peux pas répondre plus que ça. Peut-être ce que vous êtes en train de faire n'a pas réellement besoin d'un état, mais je ne peux pas vraiment vous le dire.
Sur ce site elles ne mettent pas la cond.acquire() dans le rapport d'essai, et je dirais même qu'ils sont en droit de ne pas le faire : il le rend plus compréhensible. Lorsque vous ne savez pas à ce sujet, vous êtes comme "pourquoi vous avez à mettre le acquire dans l'instruction try?". Et ce n'est pas une question pertinente que vous n'avez pas à le mettre là. Par ailleurs, le lien de site web m'a beaucoup aidé dans la compréhension de filetage en Python, espérons que ça pourrait aider quelqu'un d'autre

OriginalL'auteur roippi

Vous devez vous connecter pour publier un commentaire.