Python 스레드 동기화란 무엇입니까? 한 기사로 Python 스레드 모듈 이해하기

여러 스레드가 특정 데이터를 공동으로 수정하는 경우, 데이터의 정확성을 보장하기 위해 여러 스레드를 동기화해야 합니다.

Thread 객체의 Lock 및 Rlock을 사용하면 간단한 Thread 동기화를 얻을 수 있습니다. 두 객체 모두 한 번에 하나만 필요한 사람들을 위해 획득 방법과 해제 방법이 있습니다. 스레드에 의한 획득 방법과 해제 방법 사이에 배치될 수 있습니다. 다음과 같습니다:

Multi-threading장점은 동시에 여러 작업을 실행할 수 있다는 것입니다(적어도 그렇게 느껴집니다). 그러나 스레드가 데이터를 공유해야 하는 경우 데이터가 동기화되지 않는 문제가 발생할 수 있습니다.

상황을 생각해 보세요. 목록의 모든 요소가 0이고 스레드 "set"이 모든 요소를 ​​뒤에서 앞으로 1로 변경하고 스레드 "print"가 목록을 앞에서 뒤로 읽고 인쇄.

그런 다음 "set" 스레드가 변경되기 시작하면 "print" 스레드가 목록을 인쇄하고 출력은 0과 1의 절반이 됩니다. 이것이 데이터의 비동기화입니다. 이러한 상황을 방지하기 위해 잠금 개념이 도입되었습니다.

잠금에는 잠김과 잠금 해제의 두 가지 상태가 있습니다. "set"과 같은 스레드가 공유 데이터에 액세스하려고 할 때마다 먼저 잠금을 획득해야 합니다. "print"와 같은 다른 스레드가 이미 잠금을 획득한 경우 "set" 스레드가 일시 중지되도록 해야 합니다. 이는 동기식 차단입니다. 스레드 " Print "가 액세스가 완료되고 잠금이 해제된 후 스레드 "설정"이 계속되도록 합니다.

이런 처리를 하고 나면 목록을 인쇄할 때 모두 0이 나오거나 모두 1이 출력되게 되어 반은 0, 반은 1이 되는 민망한 장면은 더 이상 없을 것입니다.

#!/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"

위 내용은 Python 스레드 동기화란 무엇입니까? 한 기사로 Python 스레드 모듈 이해하기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!