問題タブ [job-queue]

https://github.com/yigit/android-priority-jobqueueでアクティブなジョブのリストを取得する推奨される方法があるかどうか知りたい

そうすれば、永続的なジョブがまだ待機している場合、ユーザーにそのジョブを知らせることができます。

SDK のバージョン 1.9.36 を使用して、Google App Engine で Java アプリケーションを実行しています。アプリケーションは、Datastore、BigQuery、Cloud Storage にアクセスできる Java 7 を実行しています。コンテナーは B8 クラスのバックエンド サーバーであり、いくつかの基本的なチェックを行ってから TaskQueue エントリを送信する受信サーブレットによってタスクが送信されます。

私が直面している問題は、アプリケーションが単に応答を停止することです。データは、JobQueue を使用して BigQuery テーブルから読み取られます。ジョブのステータスが RUNNING から DONE になることを確認している間、アプリケーションは単にログと処理を停止します。この待機反復回数は、アプリケーションが停止する場所によって異なります。

一貫性がないため、特定のコードに固定することはできません。

アプリケーションが何日も問題なく動作する日もあれば、停止せずに 1 回の反復を完了することさえできない日もあります。

テーブル内のデータは、600 ～ 6000 行の間で変化します。一度に 2000 行のチャンクを読み取ります。

「Job done - let process results」の部分に到達して、単に停止することがあります。いくつかの RUNNING メッセージをログに記録して停止することがあります。

これは、ジョブ パラメータを設定してからジョブを開始する部分です。do while ループのコードを省略しました。{} それはビットを処理しているだけですが、正常に動作します。どこかでデータの取得に問題があるようです。

AppEngine コンソールを見ると、インスタンスはまだ実行中として表示されますが、処理されたリクエストを示すグラフも停止します。

コードの変更や再デプロイなしで動作が非常に不安定になる、同様の経験をした人はいますか?

Java アプリケーションと AS400 の間のインターフェースを作成しています。この目的のために、jt400 を使用します。CPU 使用率などのシステム ステータスに関する情報を取得することができました。また、サブシステムとジョブに関する現在のステータスを取得することもできました。

現在、AS400 内のさまざまなジョブ キューを確認するオプションを探しています。

例: どのキューにいくつのジョブがあるか知りたいです。

java経由でこれらの情報にアクセスするためのjt400または別のアプローチによる解決策はありますか?

AS400 内の対応するコマンドは WRKJOBQ です。

ベスト L ストライク

[編集]

次のコードは、JobList のフィルターです。しかし、QSYSObjectPathName が WRKJOBQ と一致するように構成するにはどうすればよいでしょうか?

ジョブ キューを監視する Windows サービスを C# で構築しています。キューで使用可能なアイテムが見つかると、ジョブを「完全に」処理するジョブを起動します (失敗を含む)。私は Task.Factory.StartNew() を使用していますが、確かに、私は TAP に非常に慣れています (この投稿を終えた後、ブログを読みに行きます)。

要件

1. 定期的にデータベース キューをポーリングして、利用可能なジョブを探します。(この質問のために、メッセージング キューとデータベース キューの議論は無視しましょう)

2. ジョブを非同期的に起動して、ポーリングがキューを監視し続けて新しいジョブを起動できるようにします。

3. あまりにも多くのジョブが生成されないように、「ジョブ」のしきい値を尊重します。

4. ジョブが処理中の場合、サービスのシャットダウンを「遅らせます」。

5. ジョブの失敗がイベント ログに記録され、Windows サービスがクラッシュしないことを確認します。

私のコードは以下にありますが、ここに私の質問/懸念事項があります（これを投稿するより良い場所があれば教えてください）が、これは主にTAPの適切な使用とその「安定性」を中心に展開しています。私の質問のほとんどは、コードでも文書化されていることに注意してください。

質問

1. PollJobs で、Task.Factory.Start/ContinueWith を使用する方法は、このジョブ処理サービスで高いスループットを維持するために適切に使用されていますか? スレッドをブロックすることは決してありません。できれば、現在持っているわずかな TAP に対して正しいパターンを使用することを願っています。

2. ConcurrentDictionary - これを使用して現在実行中のジョブを監視し、各ジョブが終了すると、それ自体が辞書から削除されます (Task.Factory.StartNew から想定した別のスレッドで)。使用時にどこかにロックしますか？

3. ジョブの例外 (最悪の場合は OutOfMemoryException) - ジョブ処理中の例外はサービスをダウンさせることはできず、イベント ログとデータベース キューに正しく記録する必要があります。現在、残念ながら OutOfMemoryException をスローするジョブがあります。「ジョブ処理」内の try/catch は、Windows サービスが予期せず終了しないように、すべてのシナリオをキャッチして処理するのに十分ですか? それとも、ジョブごとに AppDomain を起動して分離を強化した方が安全でしょうか? （殺し過ぎ？）

4. 「適切な」タイマーを使用することについて議論する議論を見てきましたが、まともな答えはありません。System.Threading.Timer のセットアップと使用について何か意見はありますか? (具体的には、前の呼び出しが終了するまで PollJobs が再度呼び出されないようにする方法について)

ここまでできれば。前もって感謝します。

コード

次のコードがどのように実行されるのか理解できません。なぜ「1」は「b」の後にあるのに「h」は「3」の後にあるのですか? 順番は、a、b、1、2、h、3 の順でよいでしょうか? 一部の記事では、「イベント ループ キュー」と「ジョブ キュー」の違いが次の出力につながると述べています。しかし、どのように？ECMAScript 2015 - 8.4 Jobs and Job Queuesの仕様を読み、Promise'job がどのように機能するかを知りたがっていますが、さらに混乱します。誰かが私を助けることができますか？ありがとうございました！

Promise が非同期であることは知っていますが、setTimeout(..) 非同期操作のコールバックは常に Promise の非同期操作の後になります。なんで？

Nodejs で Web サイトのスクリーンショットを取得するスクリプトを作成しました (を使用slimerJs)。このスクリプトは完了するまでに約 10 ～ 20 秒かかります。ここでの問題は、このスクリプトが完了するまでサーバーが停止することです。

スクリプトはメモリ内に Firefox ブラウザを生成し、Web サイトをロードするため、RAM の使用量が 600 ～ 700 MB まで急増する可能性があり、RAM はサーバー上で高価であるため、このコマンドを非同期的に実行することはできません。

着信要求をキューに入れ、FIFO 方式で実行できるかどうかを教えてください。

kue、bull、bee-queues などのパッケージをチェックしてみましたが、これらはすべて、キューが開始される前にジョブ リストが既にわかっていることを前提としていると思います。私のジョブ リストは、サイトを使用しているユーザーに依存するためです。彼らは列に並んでいて、順番を待つ必要があります。上記のパッケージでこれは可能ですか？