問題タブ [reactor]

Epoll に基づいて、非同期パターンの Reactor を C++ で実装しています。まず、関数を呼び出してファイル記述子を Reactor に登録します。

そして、永久に実行されるメソッド hand_events が呼び出されます

この状況でストレージ モデルを整理する方法についての私の質問: ストア ハンドル、およびファイル記述子とハンドルの間のマッピング (それに適したパターンはありますか)

回答をお待ちしております。

ファイルを読み取り、いくつかの計算を行い、出力ファイルを書き込む node.js 用の JavaScript で記述した非常に単純なユーティリティ スクリプトがあります。現在の形式のソースは次のようになります。

これは正常に動作しますが、この場合、次のように、代わりにこれらの関数の同期型を使用することに何らかの欠点があるかどうか疑問に思っています。

私にとって、これはさまざまなコールバックよりも読みやすく理解しやすいものです。この場合、前者の方法を使用する理由はありますか?

ローカルで実行しているこの単純なスクリプトでは、速度はまったく問題にならないことがわかりましたが、その背後にある理論を理解することに興味があります。非同期メソッドの使用が役立つのはいつですか? 本番アプリケーションであっても、ファイルを読み取るだけで、次のタスクの実行を待機している場合、非同期メソッドを使用する理由はありますか?

これを実行して複数のクライアントを作成する場合:

どうすれば原子炉を安全に停止できますか? 私が行った場合：

プロトコルで、次のようにします。

工場では、次のクライアントが再び原子炉を停止しようとします。ただし、これはもちろんエラーにつながります。

このようなシナリオで原子炉を正常に停止するにはどうすればよいですか?

まず第一に、リアクター パターンを扱うのは初めてだと言いたいです。自分の持っている知識でいろいろ試してみましたが、うまくいきませんでした。これまでの私のスクリプトは次のとおりです。

スクリプトをテストするために、私はこれを持っています

そこで、新しいリアクター オブジェクトを作成し、それにイベント リスナーを追加して、イベントをディスパッチします。しかし、コールバック関数では、「これ」を「テスト」オブジェクトにしたいと考えています。

次のプロジェクトで Akka と Reactor のどちらを使用するかを検討しています。最も重要な問題の 1 つは、選択する将来のフレームワークがリモーティングを提供するかどうかです。私が見たように、Akka は私たちが望んでいた方法でこれを提供します。

残念ながら、GitHub wiki では、TCP サーバー/クライアントのセクションが空白であり、それに関する他の情報はまだ見つかりませんでした。

リアクターはリモーティングを提供しますか?

サーバーに問題が発生しました。

ThreadPool でタスクを実行すると、サーバーがクラッシュします。

スレッドプールが使用される関数の一部を次に示します。

ケース 666 が実行されると、サーバーがクラッシュします。(この場合のみ、テストにスレッド プールを使用します)

WorkerThreadPool クラスがあります:

そこで QuitHandler クラス:

そして定義を実行します：

ログ "app.logger().information("quith");" の前にアプリケーションがクラッシュします。

ありがとう。

ねじれたドキュメントでは、次のように述べています。

新しいアプリケーション コードは、参照を取得するためにこのモジュールをインポートできることに依存するのではなく、reactor を必要に応じてパラメーターとして受け渡しすることを優先する必要があります。これにより、単体テストが簡素化され、(パフォーマンスの向上として) 複数のリアクターをサポートすることが容易になる可能性がありますが、これは現時点では不可能です。

これを行うための好ましい方法は何ですか? 特に、それをプロトコルに渡す最良の方法は何ですか? (特に、標準の twisted.internet.protocol.Factory だけが必要な場合。)

編集：明確にするために、プロトコルは直接インスタンス化されていないため、以下の方法が好ましい方法なのか、それともプロトコルでリアクターへのアクセスを許可するより良い方法があるのか​​ 疑問に思っています。

リアクターへのアクセスを望むことはかなり一般的であるため、リアクターにアクセスするためだけにファクトリ クラスを作成するのは少しばかげているように思えます。