Autobahn Twisted websocketサーバーとSwaggerサーバーは、Pythonでマルチスレッド化されていますか？

Question

私はPythonで、この闊歩サーバ

app = connexion.App(__name__, specification_dir='./swagger/') 
app.app.json_encoder = JSONEncoder 
app.add_api('swagger.yaml', arguments={'title': ''}) 

app.run(port=8080) 

と、このWebSocketのサーバー2つの異なるスレッドで

from autobahn.twisted.websocket import WebSocketServerProtocol 
import sys 

from twisted.python import log 
from twisted.internet import reactor 
log.startLogging(sys.stdout) 

from autobahn.twisted.websocket import WebSocketServerFactory 
factory = WebSocketServerFactory() 
factory.protocol = MyServerProtocol 

reactor.listenTCP(9000, factory) 
reactor.run() 

を実行できますか？最終的に、idがswagger APIに投稿されたとき、私はこのidを私のwebsocketサーバーに転送し、それから私のwebsocketクライアントへの既存の一致接続を介して送信したいと思います。だから私は2つのスレッドでこれらの2つを実行すると、おそらく私はこのidを変数として共有できると思った。

Answer 1

非メインスレッドでTwisted reactorを実行する場合、シグナルハンドリングを無効にする必要があります（Pythonはメインスレッドでのみシグナルハンドラを許可するため）。これはいくつかの機能を無効にしますが、もしあなたがその機能を使用していないなら、これはうまくいくはずです。

ただ、原子炉をこのように起動します。

reactor.run(installSignalHandlers=False) 

これは、あなたが（すべて同じスレッドで、そのthreadsafey問題を最小化または排除する必要がある）非メインスレッドであなたのツイストコードを実行できるようになります。そうすれば、スワッガーコードをメインスレッドで実行することができます。スワッガーコードは、正常に動作するはずです（これは通常通りです）。

また、Swaggerコードをメイン以外のスレッドに、Twistedをメインスレッドに配置することもできます。非メインスレッドでSwaggerコードを実行できるようにするために必要なステップがあるかどうかはわかりません。

スレッド間でデータの受け渡しを開始するときには、変数が1つだけ書き込まれ、もう一方が読み取られる変数だけが必要なわけではありません。これは、スレッドセーフでないコードを作成するための大きな一歩です。代わりに、スレッド間のメッセージングに1つまたは複数のTwisted APIを使用します。たとえば、reactor.callFromThreadはスレッドセーフです（スレッドから安全に呼び出すことができます）。SwaggerスレッドからTwisted reactorスレッドにメッセージを送信するために使用できます。ような何か：それはちょうどから、かのようですので、あなたがスレッドの安全性の問題を持っていない自信を持って、

reactor.callFromThread(process_received_id, id) 

今process_received_id(id)は「まもなく」ツイスト原子炉のスレッドで実行され、あなたがやりたいことができます視点がprocess_received_idの場合は、シングルスレッドアプリケーションです。