Javaでの非同期プロセスのトリガー

Question

ユーザーリクエストを受け取り、それらをMYSQLデータベースに入れるWebアプリケーションがあります。これで、一般的なユーザー要求は、完了までにかなりの時間がかかるワークフローに従って処理する必要があります。これに対処するために、私は、MySQLのテーブルを聞いている非同期プロセッサを持っています。

無限ループでMYSQLテーブルをポーリングすると、アプリケーションが配備されているボックスのCPU使用率が高くなるため、そのボックスが使用できなくなることがよくあります。

私は、MYSQLデータベースにアクティブなリクエストがないときはいつでも、 'some' timeのために非同期プロセスをスリープさせることがオプションであることを知っていますが、私は最後の手段としてそれを保持したいと思います。

単一の要求の処理に伴うワークフローの時間がかかるため、またバックエンドの進化を可能にするために処理をフロントエンドから切り離す必要があるため、このプロセスを同期させることはオプションではありません。

非同期プロセスをトリガするスマートな方法があるかどうかを知りたいので、CPU使用率が急上昇するのを避け、非同期プロセッサから最適な応答時間を得ることができます。

アドバイスをいただければ幸いです。

おかげ p1ng

Answer 1

オプションは、データベースに要求を保存し、あなたのシステム内のイベントのいくつかの種類を送ることであろう（例えばJMSメッセージ、またはjava.util.concurrentの構文を使用して）。コマンドを読み込んで実行するプロセスは、このシグナルによって目を覚まし、データベース内のデータを取り出して通常どおりに処理します。

このようにして、CPUサイクルがまだ使用できないデータをポーリングするのを無駄にすることはなく、ポーリングの遅延がないため、反応がさらに強くなります。

Answer 2

非同期プロセスをTCPソケットなどから読み取ることができます。非同期プロセスは、I/Oのブロックを待つだけです。その後、プライマリプロセスから、テーブルを更新した後、非同期プロセスにメッセージを送信することができます。データベース内のトリガからメッセージを送信することも可能です。

Answer 3

私は一般に、テーブルをチェックするためにポーリングベースのアプローチをお勧めしません。異なるスケジュールで異なるイベントをポーリングする必要がある場合はどうなりますか？将来的に複数のイベントが必要な場合は、非同期タスクのメッセージキューを調べることをお勧めします。

しかし、今のところポーリングベースのアプローチをしなければならないのですが、非同期プロセスをしばらく眠らせないようにあなたの推論を完全に理解していませんか？なぜあなたのプロセスは無限ループで動作しているだけで何もしないすべてのCPUリソースを消費したいのですか？特定の間隔で非同期処理を実行するのはなぜですか？このポーリング間隔を設定可能にすることができます。

Answer 4

Java APIを使用すると、FutureTask Java APIを使用できます。 that blog entryを参照してください。

またはおそらくちょうどnew Thread(YourRunnable).start()を入力し、YourRunnableに状態変数を設定して、タスクが終了したかどうかを確認します。