Mengapakah perubahan dibuat kepada pembolehubah yang dikongsi oleh satu utas tidak dapat dilihat oleh utas lain dalam Python?

Kandungan soalan

Saya cuba menggunakan pembolehubah yang sama dalam berbilang urutan, tetapi nilai pembolehubah tidak dikemas kini secara konsisten merentas urutan. Contohnya, apabila utas 1 mengemas kini pembolehubah kepada 1, utas 2 tidak mengenali perubahan ini dan sebaliknya melihat nilai lama.

Berikut ialah contoh kod ringkas yang menggambarkan masalah tersebut. Apabila pengguna menekan kekunci "a", pembolehubah "pertanyaan" harus dikemas kini dan dipaparkan seperti ini:

1. Pertanyaan 1: a
2. Pertanyaan: a

Namun, output sebenar yang saya dapat hanyalah:

1. Pertanyaan 1: a

Bolehkah anda membantu saya memahami mengapa ini berlaku dan cara untuk membetulkannya?

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()

Jawapan betul

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

Masalahnya, setiap perubahan query 后，您都会返回到 getch，这会锁定 gil。当 getch 返回时，已经过去了足够的时间，gil 立即被移交，另一个线程检查更改，看到最后的更改并报告它，主线程最终得到返回控制权，但通常在 getch 再次锁定它之前没有做足够的事情来导致另一次 gil 切换，并且另一个线程永远没有机会运行并看到更改，直到 getch kembali lain kali. Ini mungkin berbeza-beza bergantung pada versi python (peraturan untuk menyemak gil berubah dari semasa ke semasa), tetapi ia sentiasa tidak stabil.

Penyelesaian yang betul ialah getch 模块在进行阻塞调用之前在内部释放 gil，但如果做不到这一点，您可以通过在每个 getch 之前故意以 gil 释放方式阻塞来给其他线程一些运行时间调用时，通过导入 time modul dan tambahkan tidur untuk memberi masa kepada rangkaian lain melihat perubahan terkini:

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

Ini mendapat tingkah laku yang anda jangkakan, walaupun secara teknikalnya ia tertakluk kepada syarat perlumbaan jika benang lain terlibat, tetapi untuk dua utas seperti ini ia agak boleh dipercayai.

Atas ialah kandungan terperinci Mengapakah perubahan dibuat kepada pembolehubah yang dikongsi oleh satu utas tidak dapat dilihat oleh utas lain dalam Python?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!