Was ist Python-Thread-Synchronisation? Verstehen Sie das Python-Thread-Modul in einem Artikel

Wenn mehrere Threads gemeinsam bestimmte Daten ändern, kann es zu unvorhersehbaren Ergebnissen kommen. Um die Genauigkeit der Daten sicherzustellen, müssen mehrere Threads synchronisiert werden.

Durch die Verwendung von Lock und Rlock des Thread-Objekts kann eine einfache Thread-Synchronisierung erreicht werden. Beide Objekte verfügen über Erfassungs- und Freigabemethoden für Daten, für deren Ausführung jeweils nur ein Thread erforderlich ist. Seine Operation kann zwischen den Methoden „Acquire“ und „Release“ platziert werden. Wie folgt:

Der Vorteil von Multithreading besteht darin, dass mehrere Aufgaben gleichzeitig ausgeführt werden können (zumindest fühlt es sich so an). Wenn Threads jedoch Daten gemeinsam nutzen müssen, kann es zu Problemen mit der Datensynchronisation kommen.

Stellen Sie sich eine Situation vor: Alle Elemente in einer Liste sind 0, der Thread „set“ ändert alle Elemente von hinten nach vorne auf 1 und der Thread „print“ ist dafür verantwortlich, die Liste von vorne nach hinten zu lesen und zu drucken.

Wenn sich dann der Thread „set“ zu ändern beginnt, druckt der Thread „print“ möglicherweise die Liste und die Ausgabe ist halb 0 und halb 1. Dies ist die Desynchronisation der Daten. Um diese Situation zu vermeiden, wurde das Konzept der Sperren eingeführt.

Schlösser haben zwei Zustände – gesperrt und entsperrt. Immer wenn ein Thread wie „set“ auf gemeinsam genutzte Daten zugreifen möchte, muss er zuerst die Sperre erhalten. Wenn ein anderer Thread wie „print“ bereits eine Sperre erhalten hat, muss der Thread „set“ angehalten werden, was eine synchrone Blockierung darstellt bis der Thread " Drucken "Nachdem der Zugriff abgeschlossen und die Sperre aufgehoben wurde, lassen Sie den Thread weiter "setzen".

Nach einer solchen Verarbeitung werden beim Drucken der Liste entweder alle Nullen oder alle Einsen ausgegeben, und es gibt keine peinliche Szene mehr aus halben Nullen und halben Einsen mehr.

#!/usr/bin/python
# -*- coding: UTF-8 -*-
import threading
import time
class myThread (threading.Thread):
def __init__(self, threadID, name, counter):
threading.Thread.__init__(self)
self.threadID = threadID
self.name = name
self.counter = counter
def run(self):
print "Starting " + self.name
# 获得锁，成功获得锁定后返回True# 可选的timeout参数不填时将一直阻塞直到获得锁定
# 否则超时后将返回False
threadLock.acquire()
print_time(self.name, self.counter, 3)
# 释放锁
threadLock.release()
def print_time(threadName, delay, counter):
while counter:
time.sleep(delay)
print "%s: %s" % (threadName, time.ctime(time.time()))
counter -= 1
threadLock = threading.Lock()
threads = []
# 创建新线程
thread1 = myThread(1, "Thread-1", 1)
thread2 = myThread(2, "Thread-2", 2)
# 开启新线程
thread1.start()
thread2.start()
# 添加线程到线程列表
threads.append(thread1)
threads.append(thread2)
# 等待所有线程完成
for t in threads:
t.join()
print "Exiting Main Thread"

Das obige ist der detaillierte Inhalt vonWas ist Python-Thread-Synchronisation? Verstehen Sie das Python-Thread-Modul in einem Artikel. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!