並列処理について（ProcessPoolExecutor）

Question

前提・実現したいこと

初歩的な質問で申し訳ございません。
下記のコードではなぜb関数のif文に入らないのでしょうか。
申し訳ございませんが、ご教示いただけないでしょうか。

該当のソースコード

from concurrent.futures.process import ProcessPoolExecutor
import sys
import time

class S:
    def __init__(self):
        self.n = 0
    
    def a(self):    
        self.n += 1

    def b (self):
        if self.n == 1:
            self.n += 1
            sys.exit()
                
def main():
    ex = ProcessPoolExecutor(max_workers=2)
    s = S()
    ex.submit(s.a)
    while True:
        ex.submit(s.b)
    
if __name__ =="__main__":
    main()           

Answer 1

• なぜb関数のif文に入らないのでしょうか。

s.nがゼロだからです。

以下を実行してみてください。

from concurrent.futures.process import ProcessPoolExecutor
#import concurrent.futures
import sys
import time

class S:
    def __init__(self):
        self.n = 0
    def a(self):    
        self.n += 1
        print('func_a:', self.n)
    def b (self):
        print('func_b:', self.n)
        if self.n == 1:
            self.n += 1
            print('func_b_if:')

if __name__ == '__main__':
    ex = ProcessPoolExecutor(max_workers=2)
#    ex = concurrent.futures.ThreadPoolExecutor(max_workers=2)
    s = S()
    ex.submit(s.a)
    ex.submit(s.b)
    print('parent:', s.n)

なぜ、s.nがゼロなのかは、簡単にいうと世界(メモリ空間)が違うからです。
【Python】マルチプロセスについてを読んでみてください。
これが理解できない場合はOSの勉強をしてforkを理解してください。

上記のコードのコメントを付け替えてThreadPoolExecutorの方で実行すると同じメモリ空間で実行するので、実行順序によってはfunc_b_ifが表示される場合もあります。

Comments

[reiya_123]

ご返信ありがとうございます。
aとbの関数で変数を共有するためには引数に変数を定義していけばいいような感じでしょうか。

[ppaul]

いいえ。
OSの勉強をしてforkを理解してください。