python 멀티스레드 - Semaphore(신호 대상)

Semaphore(value=1)

Semaphore 대상 내부에서 하나의 계수기를 관리하는데 이 계수기는 acquire()마다 호출되고 release()마다 호출된다.계수기는 영원히 0보다 낮지 않다. acquire()이 계수기가 0인 것을 발견하면 라인이 막히고 다른 라인이 release()을 호출하기를 기다린다.Semaphore 객체는 컨텍스트 관리 프로토콜을 지원합니다.방법: acquire(blocking=True, timeout=None)에서 신호를 받습니다.blocking=True시: 호출할 때 계수기가 0보다 크면 1을 줄이고 즉시 되돌려줍니다.만약 호출할 때 계수기가 0이면, 다른 라인이 release()을 호출해서 0보다 크게 할 때까지 막히고 기다린다.이것은 적당한 상호 잠금을 통해 이루어진 것이기 때문에 여러 개의 acquire()이 막히면 release()은 그 중 하나만 깨우고 이 과정은 무작위로 하나를 선택하기 때문에 막힌 라인의 깨우는 순서에 의존해서는 안 된다.반환 값은 True입니다.blocking=False일 때 막히지 않습니다.만약 acquire()을 호출할 때 계수기가 0이면 즉시 False을 되돌려줍니다.timeout 매개 변수를 설정하면 최대 timeout 초 동안 차단됩니다.이 시간대에 자물쇠를 얻지 못하면 False으로 돌아가고 그렇지 않으면 True으로 돌아간다.
release () 는 신호를 방출하여 계수기를 1씩 증가시킵니다.계수기가 0이고 다른 라인이 계수기가 0보다 크면 이 라인을 깨웁니다.

BoundedSemaphore(value=1)

유계 신호 대상을 실현하다.유계 신호 대상은 계수기가 초기치 value을 초과하지 않도록 확보하고, 그렇지 않으면 ValueError을 던진다.대부분의 경우, 이 대상은 유한한 용량의 자원을 보호하는 데 쓰인다.
밤:

# -*- coding:utf-8 -*-
import threading
import time


sem = threading.Semaphore(3)


class DemoThread(threading.Thread):

    def run(self):
        print('{0} is waiting semaphore.'.format(self.name))
        sem.acquire()
        print('{0} acquired semaphore({1}).'.format(self.name, time.ctime()))
        time.sleep(5)
        print('{0} release semaphore.'.format(self.name))
        sem.release()


if __name__ == '__main__':
    threads = []
    for i in range(4):
        threads.append(DemoThread(name='Thread-' + str(i)))

    for t in threads:
        t.start()

    for t in threads:
        t.join()

실행 결과:

Thread-0 is waiting semaphore.
Thread-0 acquired semaphore(Thu Oct 25 20:33:18 2018).
Thread-1 is waiting semaphore.
Thread-1 acquired semaphore(Thu Oct 25 20:33:18 2018).
Thread-2 is waiting semaphore.
Thread-2 acquired semaphore(Thu Oct 25 20:33:18 2018).
Thread-3 is waiting semaphore.
Thread-0 release semaphore.
Thread-3 acquired semaphore(Thu Oct 25 20:33:23 2018).
Thread-1 release semaphore.
Thread-2 release semaphore.
Thread-3 release semaphore.

Thread-3은 Thread-0이 방출된 후에야 신호 대상을 얻는 것을 볼 수 있다.