問題タブ [nats.io]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - NATS クライアント用の Python Tornado を使用して、遅延したノンブロッキングの自己停止をセットアップする方法
既存の機能をブロックすることなく、タイムアウト期間後に Tornado を停止させようとしています。Tornado の規則が欠けている可能性がありますが、spawn_callback、Task、または Thread を使用するかどうかは関係ありません。メイン ループを停止しているようです。
まず、私がこれを行っている理由は、クライアント アプリで世界的に有名な NATS メッセージ バスを使用してメッセージを発行し (通常の単純な HTTP 機能ではありません)、サブスクライブされた応答を待ちたいからです。非同期動作の典型的な問題であり、公式の NATS Python クライアントは Tornado を使用しているため、私もそれを使用しようとしています。
私の問題は、 tornado.gen.coroutine デコレータがスレッドでどのように機能するかを理解することに関係していると思われます。
私のコードのクリップを以下に示します。誰かが私の明らかな問題に気づいたら、ポインタをいただければ幸いです。ありがとう！
python - コルーチンの収量は引き続きメイン
NATS (nats.io メッセージング システム) にデータを送信するために、コルーチンを使用しようとしています。
このコードを引数なしで for ループで呼び出そうとすると、完全に機能します。
しかし、引数を追加すると、yield nc.connect 関数は何も返さず、メイン関数に進みます。
引数を指定してコルーチンを呼び出すにはどうすればよいですか?