Queue (2) 썸네일형 리스트형 [Python] Multiprocessing(5) - Queue, Pipe 프로세스 통신 - Queue 방식 from multiprocessing import Process, Queue, current_process import time import os # 실행 함수 def worker(id, baseNum, q): process_id = os.getpid() process_name = current_process().name print(f"Process ID: {process_id}, Process Name: {process_name}") # 누적 sub_total = 0 # 계산 for i in range(baseNum): sub_total += 1 # time.sleep(0.1) # Produce q.put(sub_total) # 정보 출력 print(f"*** Sub .. [Python] Thread(5) - Producer and Consumer Using Queue 큐를 이용한 생산자 소비자 구조의 스레드 import concurrent.futures import logging import queue import random import threading import time # 생산자 def producer(queue, event): ''' 네트워크 대기 상태라 가정(서버) ''' while not event.is_set(): message = random.randint(1,101) logging.info('Producer got message: {}'.format(message)) queue.put(message) logging.info('Producer received event Exiting') # 소비자 def consumer(queue, event): '.. 이전 1 다음