병렬로 여러 클래스의 클래스 메서드를 실행할 때 클래스 상태를 유지하는 방법은 무엇입니까?

Question

아래 예제에서 멀티 프로세싱을 사용할 때 n을 어떻게 늘릴 수 있습니까? [k.n for k in klasses]가 예상대로 [0, 0, 0, 0]를 생산 실행

class Test: 
    def __init__(self, n): 
     self.n = n 

    def run(self): 
     self.n += 1 
     return True 

# Generate 4 classes 
klasses = [Test(0) for i in range(4)] 

. 사용하여 병렬로 각 클래스의 기능 run()를 실행하려고

: 예상대로

from multiprocessing import Pool  
with Pool() as pool: 
    results = [pool.apply_async(k.run,()) for k in klasses ] 
    result = [i.get() for i in results] 

결과 result에서는 [True, True, True, True]를 반환. [k.n for k in klasses] 결과가 [0, 0, 0, 0]이 되어도 클래스 'n'속성은 변경되지 않았습니다. 방법이 병렬로 처리되지 않는 경우. [k.run() for k in klasses], [k.n for k in klasses]은 예상대로 [1, 1, 1, 1]을 반환합니다.

클래스가 병렬로 실행될 때 상태를 유지할 수있는 방법이 있습니까?

Answer 1

각 작업자가 별도의 프로세스이므로 multiprocessing의 공유 상태를 명시 적으로 수행해야합니다. multiprocessing docs cover the various options in so detail. 가장 간단한 해결책은 n을 multiprocessing.Value으로 만드는 것이지만, 적절한 유형 및 특성을 사용하도록 Test 클래스를 크게 변경해야합니다.

또는 pool.imap/pool.imap_unordered을 사용하여 작업을 수행하는 방법을 찾고 상태가 인수로 전달되고 새 데이터가 반환됩니다. 이런 식으로 문제를 표현할 수 있다면 라이브 상태가 아닌 입력 및 출력으로 공유를 제한하는 것이 더 좋습니다.