同じPythonスクリプトの複数の実行インスタンスに更新イベントを通知する必要があります

Question

Pythonスクリプトの実行中のインスタンスすべてに更新イベントを通知する必要があり、できるだけシンプルにコードを保持したいと考えています。私は、実行中のプロセス間での通信経験はありません。これまで、私は各インスタンスが読み書きする構成ファイルを読み書きしていました。

私はこの問題を解決する方法について私の頭を包むために書いた（シンプルなテンプレートの一種）いくつかの擬似コードを示します。空白を埋めるのを手伝ってください。覚えておいて、私はソケット、スレッドなどの経験がありません。

import process # imaginary module 

class AppA(): 
    def __init__(self): 
     # Every instance that opens will need to attach 
     # itself to the "Instance Manager". If no manager 
     # exists, then we need to spawn it. Only one manager 
     # will ever exist no matter how many instances are 
     # running. 
     try: 
      hm = process.get_handle(AppA_InstanceManager) 
     except NoSuchProgError: 
      hm.spawn_instance(AppA_InstanceManager) 
     finally: 
      hm.register(self) 
     self.instance_manager = hm 

    def state_update(self): 
     # This method won't exist in the real code, however, 
     # it emulates internal state changes for the sake of 
     # explaination. 
     # 
     # When any internal state changes happen, we will then 
     # propagate the changes outward by calling the 
     # appropriate method of "self.instance_manager". 
     self.instance_manager.propagate_state() 

    def cb_state_update(self): 
     # Called from the "Instance Manager" only! 
     # 
     # This may be as simple as reading a known 
     # config file. Or could simply pass data 
     # to this method. 


class AppA_InstanceManager(): 
    def __init__(self): 
     self.instances = [] 

    def register_instance(self, instance): 
     self.instances.append(instance) 

    def unregister_instance(self, instance): 
     # nieve example for now. 
     self.instances.remove(instance) 

    def propagate_state(self): 
     for instance in self.instances: 
      instance.cb_state_update(data) 

if __name__ == '__main__': 
    app = AppA() 

何か提案がありますか？

Answer 1

この種のデザインにはいくつかのオプションがあります。

このような種類のメッセージキューを使用することができます。 AMQPまたは何らかのZeroMQまたはそのようなもの。

または、Redisやその他の（メモリ内の）データベースを同期用に使用できます。

このようなものを使用したくない場合は、マルチプロセッシングモジュールの同期処理を使用できます。

プラットフォーム固有のIPCシステムを使用してください。 mmap、sysvソケットなどを介した共有メモリ

説明したようにしたい場合は、Twistedsパースペクティブブローカーを見ることができます。