Python 멀티스레딩에서 블로킹(조인)과 잠금(Lock) 사용에 대한 오해 분석

이 기사는 주로 모든 사람이 자세히 알아볼 수 있도록 작성되었습니다. 이 글은 특정 참조 값을 갖는 Python 멀티스레딩의 조인 및 잠금 차단에 대한 오해를 소개합니다. 관심 있는 친구는

메인 스레드 차단의 잘못된 사용법에 대해

join

Thread.join( ) 함수는 메인 스레드를 차단하는 것입니다. 즉, 하위 스레드가 반환되지 않으면 메인 스레드는 반환을 기다린 다음 실행을 계속합니다.

join은 루프에서 시작과 함께 사용할 수 없습니다.
The 다음은 오류 코드입니다. 5개의 스레드를 생성한 다음 루프를 사용하여 스레드를 활성화한 다음 활성화 후 기본 스레드를 차단합니다.

1. 메인 스레드는 시작 함수를 통해 스레드 1을 활성화하고 스레드 1은 계산을 수행합니다.

2. 시작 함수는 메인 스레드를 차단하지 않으므로 스레드 1이 작업을 수행하는 동안 메인 스레드는 아래쪽으로 조인 함수를 실행합니다. 조인을 실행한 후 메인 스레드는 스레드 1에 의해 차단됩니다. 스레드 1이 결과를 반환하기 전에 스레드는 다음 주기를 실행할 수 없습니다.

4. 스레드 1의 계산이 완료된 후 메인 스레드의 차단을 해제합니다. .메인 스레드는 다음 주기에 진입하여 스레드 2를 활성화하고 이에 의해 차단됩니다...

이렇게 하면 동시여야 했던 5개의 스레드가 여기서 순차 대기열이 되어 효율성이 향상되는 것을 볼 수 있습니다.

join


의 올바른 사용법은 두 개의 루프를 사용하여

start

및

join

기능을 각각 처리할 수 있습니다.

threads = [Thread() for i in range(5)]
for thread in threads:
  thread.start()
  thread.join()

time .sleep은 디버깅을 위해 조인을 대체합니다이전 일부 프로젝트에서 조인 대신 time.sleep을 사용하여 메인 스레드를 수동으로 차단하는 이러한 코드를 본 적이 있습니다.

모든 하위 스레드에서 반환 이전에는 메인 스레드가 무한 루프에 걸렸고 종료할 수 없습니다.

threads = [Thread() for i in range(5)]
for thread in threads:
  thread.start()
for thread in threads:
  thread.join()

스레딩 잠금 정보(threading.Lock)

단일 코어 CPU+PIL에도 잠금이 필요합니까?

비원자적 연산

count = count + 1

이론적으로, 3개의 스레드를 사용하여 위의 작업을 동시에 수행하여 전역 변수 개수의 값을 변경하고 프로그램 실행 결과를 확인합니다. 결과가 정확하면 스레드가 없다는 의미입니다.

다음 코드를 사용하여

for thread in threads:
  thread.start()
while 1:
  if thread_num == 0:
    break
  time.sleep(0.01)

실행 결과:

count=275552

실제로 각 실행의 결과가 다르고 부정확합니다. 이는 단일 코어 CPU+ PIL은 여전히 ​​스레드 안전성을 보장할 수 없으며 잠겨야 합니다.

잠금 후 올바른 코드:

# -*- coding: utf-8 -*-
import threading
import time
count = 0
class Counter(threading.Thread):
  def __init__(self, name):
    self.thread_name = name
    super(Counter, self).__init__(name=name)
  def run(self):
    global count
    for i in xrange(100000):
      count = count + 1
counters = [Counter('thread:%s' % i) for i in range(5)]
for counter in counters:
  counter.start()
time.sleep(5)
print 'count=%s' % count

결과:

count=500000

잠금의 전역 특성에 주의하세요

이는 단순한 Python 구문 문제이지만 논리가 복잡할 때 발생합니다. 무시할 수 있습니다.

잠금이 여러 하위 스레드에서 공유되는지 확인하세요. 즉, Thread의 하위 클래스 내에 잠금을 생성하지 마세요.

다음은

오류 코드

# -*- coding: utf-8 -*-
import threading
import time
count = 0
lock = threading.Lock()
class Counter(threading.Thread):
  def __init__(self, name):
    self.thread_name = name
    self.lock = threading.Lock()
    super(Counter, self).__init__(name=name)
  def run(self):
    global count
    global lock
    for i in xrange(100000):
      lock.acquire()
      count = count + 1
      lock.release()


counters = [Counter('thread:%s' % i) for i in range(5)]

for counter in counters:
  counter.start()

time.sleep(5)
print 'count=%s' % count

입니다. 관련 권장 사항: Python 스레드의 동기화 잠금에 대한 자세한 설명

위 내용은 Python 멀티스레딩에서 블로킹(조인)과 잠금(Lock) 사용에 대한 오해 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!