>  기사  >  백엔드 개발  >  Python 3.x에서 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법

Python 3.x에서 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법

WBOY
WBOY원래의
2023-07-31 18:36:231459검색

Python 3.x에서 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법

소개:
Python에서는 다중 코어 CPU의 인기로 인해 다중 프로세스 프로그래밍이 중요한 기술이 되었습니다. multiprocessing 모듈은 다중 프로세스를 처리하기 위한 Python의 표준 라이브러리입니다. 이 기사에서는 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법을 소개하고 코드 예제를 통해 이를 설명합니다.

1. 다중 처리 모듈 소개
Python의 다중 처리 모듈은 Python 프로그램을 매핑하여 여러 프로세스에서 실행할 수 있는 래퍼를 제공합니다. 다중 처리 모듈은 스레드로부터 안전하며 스레딩 모듈보다 더 많은 기능을 제공합니다.

2. 멀티프로세싱 모듈의 공통 함수 및 클래스

  1. multiprocessing.Process 클래스
    multiprocessing.Process 클래스는 프로세스를 생성하고 관리하는 데 사용됩니다. 여기에는 4가지 주요 메소드가 있습니다:
  2. start(): 프로세스를 시작하고 run() 메소드를 호출합니다.
  3. run(): 프로세스의 진입 기능은 사용자가 정의해야 합니다.
  4. join([timeout]): 프로세스가 끝날 때까지 기다립니다. 시간 초과를 지정하지 않으면 프로세스가 끝날 때까지 기다립니다.
  5. is_alive(): 프로세스가 아직 실행 중인지 확인합니다.
  6. multiprocessing.current_process() 함수
    multiprocessing.current_process() 함수는 현재 프로세스의 Process 객체를 반환합니다.
  7. multiprocessing.active_children() 함수
    multiprocessing.active_children() 함수는 현재 프로세스에서 생성된 하위 프로세스만 포함하여 실행 중인 하위 프로세스 목록을 반환합니다.
  8. multiprocessing.Pool 클래스
    multiprocessing.Pool 클래스는 여러 프로세스의 실행을 쉽게 관리할 수 있는 프로세스 풀을 만드는 데 사용됩니다. 가장 일반적으로 사용되는 메서드는 다음과 같습니다.
  9. apply(func, args): 함수를 동기적으로 실행하고 결과를 반환합니다.
  10. apply_async(func, args): 함수를 비동기적으로 실행하고 AsyncResult 객체를 반환합니다.
  11. close(): 프로세스 풀을 닫고 더 이상 새 작업을 수락하지 않습니다.
  12. join(): 기본 프로세스는 모든 하위 프로세스가 끝날 때까지 기다립니다.

3. 다중 처리 모듈을 사용하는 샘플 코드
다음은 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법을 보여주는 간단한 예입니다.

import multiprocessing

def worker(name):
    print('Worker %s' % name)
    return name

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=4)
    results = []
    
    for i in range(4):
        result = pool.apply_async(worker, args=(i,))
        results.append(result)

    pool.close()
    pool.join()
    
    for result in results:
        print(result.get())

위 코드에서는 먼저 이름을 허용하는 작업자 함수를 정의합니다. 매개변수를 선택하고 이름을 인쇄합니다. 그런 다음 기본 프로그램에서 multiprocessing.Pool을 사용하여 4개의 프로세스가 포함된 프로세스 풀을 만듭니다. 다음으로, apply_async 메서드를 사용하여 작업자 함수를 비동기적으로 실행하고, 매개변수 i를 전달하고, 이를 결과 목록에 추가합니다. 마지막으로 pool.close() 및 pool.join() 메서드를 통해 모든 프로세스의 실행이 완료될 때까지 기다립니다. 마지막으로 result.get() 메소드를 통해 실행 결과를 얻어서 출력합니다.

위 코드를 실행하면 다음과 같은 결과가 출력됩니다.

Worker 0
Worker 1
Worker 2
Worker 3
0
1
2
3

요약:
멀티프로세싱 모듈을 사용하면 멀티프로세스 프로그래밍을 쉽게 수행할 수 있습니다. 이 문서에서는 multiprocessing 모듈의 일반적인 기능과 클래스를 소개하고 샘플 코드를 통해 이를 사용하는 방법을 보여줍니다. 멀티프로세싱 모듈을 사용하면 멀티 코어 CPU 활용도가 향상되고 프로그램 실행 효율성이 향상됩니다.

참조:
[1] Python 공식 문서 - 다중 처리 모듈 https://docs.python.org/3/library/multiprocessing.html

위 내용은 Python 3.x에서 다중 프로세스 관리를 위해 다중 처리 모듈을 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.