Process module

from multiprocessing import Process def print_func(num): for i in range(num): print("Print number %d" % i) if __name__ == "__main__": p = Process(target=print_func, args=(5,)) # Process 인스턴스 생성 p.start() # 새로운 프로세스 시작 p.join() # 프로세스의 종료를 기다림

# 프로세스 메모리 공유 예제(공유 성공!) from multiprocessing import Process, current_process, Value import os # 실행 함수 def generate_update_number(v : int): for i in range(50): v.value += 1 print(current_process().name, "data", v.value) def main(): # 부모 프로세스 아이디 parent_process_id = os.getpid() # 출력 print(f"Parent process ID {parent_process_id}") # 프로세스 리스트 선언 processes = list() # 프로세스 메모리 공유 변수 선언 share_value = Value('i', 0) # i는 정수형을 의미, 0은 초기값 for _ in range(1,10): # 생성 p = Process(target=generate_update_number, args=(share_value,)) # 배열에 담기 processes.append(p) # 실행 p.start() # Join for p in processes: p.join() # 최종 프로세스 부모 변수 확인 print("Final Data(share_value) in parent process", share_value.value) if __name__ == '__main__': main()

# 프로세스 간 통신을 위한 파이프 사용 예제 from multiprocessing import Process, Pipe # 메시지를 보내는 함수 def send_messages(conn, messages): for message in messages: print(f"Sending: {message}") conn.send(message) conn.close() # 메시지를 받는 함수 def receive_messages(conn, num_messages): print("Receiving...") for _ in range(num_messages): message = conn.recv() print(f"Received: {message}") if __name__ == '__main__': # 파이프 생성 parent_conn, child_conn = Pipe() # 메시지 생성 messages = ["Hello", "World", "!"] # 메시지 전송 프로세스 생성 p1 = Process(target=send_messages, args=(child_conn, messages)) p1.start() # 메시지 수신 프로세스 생성 p2 = Process(target=receive_messages, args=(parent_conn, len(messages))) p2.start() # 프로세스가 종료될 때까지 기다림 p1.join() p2.join()

# 프로세스 간 통신을 위한 큐 from multiprocessing import Process, Queue def func(q, message): q.put(message) if __name__ == '__main__': # 큐 생성 q = Queue() # 프로세스 생성 a = Process(target=func, args=(q,[42, None, 'hello'])) b = Process(target=func, args=(q,[111, True, 'world'])) c = Process(target=func, args=(q,"wow")) a.start() b.start() print(q.get()) # prints "[42, None, 'hello']" print(q.get()) # prints "[111, True, 'world']" c.start() a.join() b.join() print(q.get()) # prints "wow" c.join()