Python Observerパターンの実装

前提

Observerパターンを使用してスレッド処理をコーディングしています。

実現したいこと

Worker A, WorkerBの処理を同時に開始させ、WorkerA,Bの処理が終了した後にWorkerCの処理を開始したいです。
監視対象である変数(model.watch_variable)の変更で上記を制御したいと考えています。
監視対象の変数で上記の制御ができなければ、threading.Threadクラスのjoin()や、threading.Eventクラスのwait(),set()でも実現できそうなのですが、どのように実装すればいいのでしょうか。
現状はすべてのWorkerが同時に処理を始めてしまいます。

該当のソースコード

Python
1def main():
2    
3    #インスタンス生成
4    A = WorkerA()
5    B = WorkerB()
6    C = WorkerC()
7    model = Model()
8    
9    #イベントハンドラをリストに格納
10    model.eh += A.inifile_read       #inifile読込
11    model.eh += B.folder_create      #フォルダ作成
12    
13    #監視対象の変数を変更 → リストに格納されたイベントハンドラが実行
14    model.watch_variable = 1
15    
16    #イベントハンドラのリストをクリア
17    model.eh.clear()
18    
19    #イベントハンドラをリストに格納
20    model.eh += C.excel_file_write   #エクセル書き込み
21    
22    #監視対象の変数を変更 → リストに格納されたイベントハンドラが実行
23    model.watch_variable = 2
24    
25
26if __name__ == '__main__':
27    main()

Python
1import threading
2
3class EventHandler(object):
4    
5    def __init__(self):
6        self.eventhandler = []
7        
8    def __iadd__(self, handler):
9        if handler not in self.eventhandler:
10            self.eventhandler.append(handler)
11        return self
12    
13    def __isub__(self, handler):
14        self.eventhandler.remove(handler)
15        return self
16    
17    def fire(self):
18        for func in self.eventhandler:
19            threading.Thread(target=func).start()
20            
21    def clear(self):
22        self.eventhandler.clear()
23        return self
24
25class Model:
26    
27    def __init__(self):
28        self.eh = EventHandler()
29        self.__watch_variable = None  #監視対象の変数
30    
31    @property
32    def watch_variable(self):
33        return self.__watch_variable
34    
35    
36    #監視対象変数のセッター
37    @watch_variable.setter
38    def watch_variable(self, value):
39        if not self.__watch_variable == value:
40            self.__watch_variable = value
41            self.eh.fire()
42    
43

Python
1import time
2
3class WorkerA:
4    
5    def __init__(self):
6        pass
7    
8    #実処理
9    def inifile_read(self):
10        print('workerA : Start')
11        time.sleep(5)
12        print('workerA : Stop')
13
14
15class WorkerB:
16    
17    def __init__(self):
18        pass
19    
20    #実処理
21    def folder_create(self):
22        print('workerB : Start')
23        time.sleep(7)
24        print('workerB : Stop')
25
26
27class WorkerC:
28    
29    def __init__(self):
30        pass
31    
32    #実処理
33    def excel_file_write(self):
34        print('workerC : Start')
35        time.sleep(7)
36        print('workerC : Stop')
37

補足情報（FW/ツールのバージョンなど）

Python3.10
VScode
Windows 10

行動規範の内容に同意します

回答1件

ベストアンサー

要件が「まとめて fire() させたスレッドが終わるのを（メインスレッドで）待つ」という理解でよいのであれば、
下記のようにまとめて登録したスレッドの実行毎に join を使用してはいかがでしょうか。

py
1class EventHandler(object):
2    
3    def __init__(self):
4        self.eventhandler = []
5        self.threads = []
6
7    def __iadd__(self, handler):
8        if handler not in self.eventhandler:
9            self.eventhandler.append(handler)
10        return self
11    
12    def __isub__(self, handler):
13        self.eventhandler.remove(handler)
14        return self
15    
16    def fire(self):
17        for func in self.eventhandler:
18            th = threading.Thread(target=func)
19            self.threads.append(th)
20            th.start()
21
22        for th in self.threads:
23            th.join()
24            
25                        
26    def clear(self):
27        self.eventhandler.clear()
28        self.threads.clear()
29        return self