java.util.concurrent

    0

    1答えて

    ボタンをクリックすることで、ユーザーはいくつかの計算を行うタスク(Callable)を作成します。私は、タスクが終了したときに反応できるようにしたい。 Future.get()を使用するとアプリケーションがブロックされます。 Callableが結果を返すときに反応する方法はありますか? private static void startTask(int i){ try{ Fu

    0

    1答えて

    私はJsoupに基づいてパーサを作った。このパーサは、ページ番号付きのページを処理します。このページには、たとえば、解析される100のリンクが含まれています。私は改ページを行うメインループを作成しました。そして、私は非同期タスクを実行して、各ページの100項目を解析する必要があります。私が理解するように、Jsoupは非同期要求処理をサポートしていません。各アイテムを処理した後、DBに保存する必要が

    0

    1答えて

    あまりに頻繁ではない1日に1〜2回更新されるアカウントのリストがあります。 このデータには、かなりの間隔で「含む」ルックアップがあります。 理想的なデータ構造はConcurrentLinkedListでしたが、残念ながらそれはありません。 CopyOnWriteArrayListは唯一の優先オプションですか?

    -1

    2答えて

    私は、複数のスレッドがログの1つを書き込むことができるログを実装しています。List最後のスレッドはListの内容をファイルに書き込む必要があります。したがって、最後にListに書き込むスレッドは、Listをファイルにフラッシュする必要があります。これを達成する最良の方法は何ですか? Listの場合、複数のライターと1つのリーダーにとって効率的な並行クラスの1つが必要です。

    2

    2答えて

    複数のスレッドが自分自身を登録するマネージャクラスがあります(要求ごとに一意の識別子を生成するためにUUIDを使用します)。マネージャー。私はjava.util.concurrent.ExecutorServiceを使って複数のスレッドを起動しています。ここではここ public class ManagerTest { public static void main(String[] a

    1

    1答えて

    私は、java.until.concurrentの世界に新人です。 ConcurrentHashMapをコードに適用する前に、洞察が必要です。理論的にはマップは内部で16個のメタメリズムにセグメント化されています(カスタマイズ可能ですが、デフォルトセグメンテーション)。処理中はそれぞれ異なるスレッドに対応します。これで2つ以上のスレッドがマップ上のコンテンツを操作しようとしています...それで、同

    3

    4答えて

    次のコードは、Listへの同時アクセスでスレッドセーフですか? volatile修飾は、ここに任意の値を追加しますか? class concurrentList{ private AtomicBoolean locked = new AtomicBoolean(true); volatile List<Integer> list=new LinkedList<Intege

    0

    1答えて

    データベースから毎分1バッチのメッセージ(約20メッセージ)を選択し、同時に処理する必要があります。私は毎分データベースからメッセージをフェッチするためにEJBタイマーサービス(Scheduler)を使用しています。 基本的に私は毎分20〜30のメッセージを選ぶ必要があり、これらを処理した後、私はいくつかのメールを送る必要があります。メッセージの処理に関連するデータベース操作はほとんどありません。

    2

    1答えて

    マルチコア並列処理を使用して、大きなグラフに対してアルゴリズムを同時に実行したいと考えています。私はしばらくそれに取り組んできましたが、良い解決策を考え出すことはできませんでした。 これはナイーブなアルゴリズムです: W - a very large number double weight = 0 while(weight < W) - v : get_random_node_

    0

    1答えて

    私は違いを確認することはできません。私はこれを読んだ: それをテストしたい。ここでコードが行く:ここ public class Test { public static void main(String[] args){ Test test = new Test(); test.inturreptWork(); //Main group System.ou