Thread(5) - Prod and Cons Using Queu... - 인프런

안녕하세요..강사님 패스트캠퍼스에서 부터 강의 잘 듣고 있습니다.

클래스 안에서의 동작이 잘 되질 않네요..

class main():
# 생산자
    def producer(self,queue, event):
        """네트워크 대기 상태라 가정(서버)"""
        while not event.is_set():
            message = random.randint(1, 11)
            logging.info("Producer got message: %s", message)
            queue.put(message)

        logging.info("Producer received event. Exiting")

    # 소비자
    def consumer(self,queue, event):
        """응답 받고 소비하는 것으로 가정 or DB 저장"""
        while not event.is_set() or not queue.empty():
            message = queue.get()
            logging.info(
                "Consumer storing message: %s (size=%d)", message, queue.qsize()
            )

        logging.info("Consumer received event. Exiting")

if __name__ == "__main__":
    # Logging format 설정
    format = "%(asctime)s: %(message)s"
    logging.basicConfig(format=format, level=logging.INFO,
                        datefmt="%H:%M:%S")

    # 사이즈 중요
    pipeline = queue.Queue(maxsize=10)

    # 이벤트 플래그 초기 값 0
    event = threading.Event()

    # With Context 시작
    with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
        executor.submit(main.producer, pipeline, event)
        executor.submit(main.consumer, pipeline, event)

        # 실행 시간 조정
        time.sleep(0.1)

        logging.info("Main: about to set event")
        
        # 프로그램 종료
        event.set()

인프런 커뮤니티 질문&답변

Thread(5) - Prod and Cons Using Queue 강의중 궁금한게 생겼습니다