concurrenthashmap

0熱

1答えて

"Cay S Horstman"による "Java SE 8 for Really Impatient"の演習5第6章を解決しようとしています。ここに質問があります：複数のスレッドがファイルのコレクションからすべての単語を読み取るアプリケーションを作成します。 ConcurrentHashMap>を使用して、各単語が含まれるファイルを追跡します。マージメソッドを使用してマップを更新します。私は

0熱

2答えて

同時ハッシュマップの同期ブロックを使用していますか？

私の理解しているように、ConcurrentHashMapは、同時ハッシュマップ例外を取得することなく、複数のスレッドが同じハッシュマップ上で読み書きできるようにします（追加/削除）。私は4つのスレッドを持ち、各スレッドはハッシュマップを更新できます。私は、現在のスレッドがそれを更新している間に他のスレッドがハッシュマップに書き込み/更新しないようにします。 ConcurrentHashMap<

0熱

2答えて

シナリオ：ConcurrentHashMapを使用する理由

最近、私は私が運転を下回るサポートするために実装する必要のあるキャッシュを与えられた議論に巻き込まれた：今の質問はキャッシュを実装するために、マルチスレッドのシナリオでは、ある int getData(String key){ if(cache.get(key) !=null){ return cache.get(key); } else { int

2熱

1答えて

更新を失わずにショッピングカートを更新する

メソッドdefをsynchronizedブロックに入れて、これをConcurrentHashMapで解決できるかどうか疑問に思っていますか？ /** Implement thread-safe updating of user's cart. Exit criteria is carts is updated atomically, product is appended

0熱

1答えて

jgroupレプリケートされたハッシュマップで状態転送のタイムアウトを与えるには？

Jgroupクラスタリングで状態転送のタイムアウトを指定するにはどうすればよいですか？ public static ReplicatedHashMap<Integer, BaseSeatLayout> _baseSeatLayoutCache; JChannel baseRouteCache = new JChannel(props); baseRouteCache.connect("Mast

-2熱

2答えて

ConcurrentMapにスレッドを格納するのは安全ですか？

私は自分のサービスへのREST呼び出しによって新しいスレッドを作成するバックエンドサービスを構築しています。スレッドが5分かかると何も受け取らない場合、スレッドは別のREST呼び出しを待機します。すべてのスレッドを追跡するために、現在実行中のすべてのスレッドを追跡するコレクションがあるため、ユーザーがアクションを受け入れたり却下したりするなど、REST呼び出しが最後に来ると、userIDを使用し

0熱

1答えて

concurrentHasMapとAtomic Values

My Rest APIが正常に動作します。しかし、私は同時実行性の問題に懸念していますが、私はスクリプトを使ってテストしましたが、まだ見ていません。私の研究では、ConcurrentHasMapでAtomic Valuesを利用することに関して、何が汚い読みになるかを避けるためのいくつかの資料に遭遇しました。私の質問は二重です。まず、私の実装を考えれば、私は心配すべきですか？第二に、もし私がそうで

1熱

1答えて

ConcurrentMapから現在のすべてのエントリを取得して削除します

私はConcurrentHashMapに定期的に送信する必要のある変更をいくつか蓄積しています（ある種類の複製の場合）。変更に関しては、キーに関する最新の値のみが重要です。スナップショットを取得して削除する必要があります。スナップショットはアトミックである必要はなく、各エントリが操作中のある瞬間に元のマップの状態を反映していれば十分です。重要な点は、結果に存在し、最新のエントリのみが元のマップ

3熱

1答えて

Java 8 ConcurrentHashMapの初期化

ConcurrentHashMapを初期化する「CLEAN & Simple」メソッドを探しています。私は、この持っているのJava 8で： - 所望の最終結果を提供 private static final Map<String, String> myStreamedMap = Stream.of( new AbstractMap.SimpleImmutableEntry<>("Ke

-1熱

2答えて

Iambda表現コンパイルエラー

私はこのようなConcurrentHashMapのの検索を使用しています： map.search(1, (k, v) -> { return v.size() > 10 ? k : null; }); しかし、私はそれは私にコンパイルエラーを与える括弧削除する場合： map.search(1, (k, v) -> return v.size() > 10 ? return