Pourquoi les modifications apportées aux variables partagées par un thread sont-elles invisibles pour les autres threads en Python ?

Contenu de la question

J'ai essayé d'utiliser la même variable dans plusieurs threads, mais la valeur de la variable n'était pas mise à jour de manière cohérente dans tous les threads. Par exemple, lorsque le thread 1 met à jour une variable sur 1, le thread 2 ne reconnaît pas cette modification et voit à la place l'ancienne valeur.

Voici un exemple de code simple illustrant le problème. Lorsque l'utilisateur appuie sur la touche "a", la variable "requête" doit se mettre à jour et s'afficher comme ceci :

1. Requête 1 : a
2. Requête : a

Cependant, le résultat réel que j'obtiens est simplement :

1. Requête 1 : a

Pouvez-vous m'aider à comprendre pourquoi cela se produit et comment y remédier ?

import getch
import threading

QUERY = ""
EXIT_THREAD = False
def input_thread():
    global EXIT_THREAD
    last_query = ""
    while not EXIT_THREAD:
        if last_query != QUERY:
            last_query = QUERY
            print(f"Query: {QUERY}")

thread = threading.Thread(target=input_thread)
thread.start()
while True:
    char = getch.getch()
    if char == "\n":
        break
    elif char == "\x7f":
        QUERY = QUERY[:-1]
    else:
        QUERY += char
    print(f"Query1: {QUERY}")
# kill input thread
EXIT_THREAD = True
thread.join()

Bonne réponse

La question est getch 模块编码很差。当它阻塞等待输入时，它不会释放gil（全局解释器锁），因此您的其他线程不允许运行。与锁同步并没有多大帮助； gil 已保护对 query l'accès.

Le problème est que chaque changement query 后，您都会返回到 getch，这会锁定 gil。当 getch 返回时，已经过去了足够的时间，gil 立即被移交，另一个线程检查更改，看到最后的更改并报告它，主线程最终得到返回控制权，但通常在 getch 再次锁定它之前没有做足够的事情来导致另一次 gil 切换，并且另一个线程永远没有机会运行并看到更改，直到 getch revient la prochaine fois. Cela peut varier selon la version de python (les règles de vérification de gil changent de temps en temps), mais c'est toujours instable.

La bonne solution est de getch 模块在进行阻塞调用之前在内部释放 gil，但如果做不到这一点，您可以通过在每个 getch 之前故意以 gil 释放方式阻塞来给其他线程一些运行时间调用时，通过导入 timele module et d'ajouter un sleep pour donner aux autres discussions le temps de voir les dernières modifications :

while True:
    time.sleep(0.001)  # Explicitly releases GIL for a millisecond
    char = getch.getch()

Cela obtient le comportement que vous attendez, bien que techniquement, cela soit soumis aux conditions de concurrence si d'autres threads sont impliqués, mais pour deux threads comme celui-ci, c'est assez fiable.

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!