java.util.concurrent

0熱

1答えて

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

0熱

2答えて

CopyOnWriteArrayList（cowal）

私はこの概念をいくつかのチュートリアルから理解していましたが、あるスレッドがリストを反復している間、他のスレッドは基になるリストを変更することができ、ConcurrentModificationException（CME）を取得できません。 CMEを入手してください。しかし、次のプログラムではスレッド（メインスレッド）は1つのみですが、CMEを取得しています。なぜですか？イテレータですか？ A

2熱

1答えて

Java Concurrency - 誰でも出力を助けることができます。なぜリストは空ですか？

リスト内に値を挿入する2つのタスクを作成しました。実行者サービスを使用してこれらのタスクを実行します。最後に、これらのリスト内の値を調べてみます。実行者サービスがシャットダウンされると、値がリストに挿入されないのはなぜですか？この現象の背後にある理由を特定できない場合は、これを説明できます。 package com.executors; import java.util.ArrayLis

0熱

3答えて

ScheduledThreadPoolExecutor並行タスク

私はこのテーマについて多くの研究をしましたが、有用な情報は見つかりませんでした。そして、私はこのプラットフォームについての最初の質問をすることに決めました。だから、私はスケジュールされたエグゼキュータを使用して特定の期間にタスクを繰り返す。すべて順調。しかし、誤解があります....私のコードはタスクを実行しますが、タスクがスケジュール時間より長くかかる場合、タスクを終了するのを待ってから、新しいタ

0熱

2答えて

スレッドセーフな方法でコレクションを繰り返しながらリスト内の要素を集める

Salesforce fetchSize = 100を設定しましたが、クエリのために100の要素をフェッチしません。したがって、ConsumerIteratorからの単一の結果をリストに集めて、バッチプロセスに100のセットで渡すことができるようにしたいと考えています。以下のコードがあります。これは正しい方法ですか？私はそれを正しく行う方法に関する提案を感謝します。すべてのConsumerIter

1熱

1答えて

Javaのネストされたキュー

更新：要するに、私はサービスへのユーザーからメッセージを送信キューを持っています。しかし、1つのサービスが1000sのメッセージを受け取ると、キューはによって支配され、それ以外のサービスはキューが空になるまでメッセージを受信しません。私はこれを解決するためにのアプローチが必要です。 BlockingQueue'sに問題があります。私はそれらにメッセージを配信する責任がある100の外部サービ

1熱

1答えて

ConcurrentSkipListMapのキーとなる要素を削除するには？

私はConcurrentSkipListMapです。私はkey以下の要素を削除する必要があります。ここでは、私はそれを行うことができる方法です。 private ConcurrentNavigableMap<Double, MyObject> myObjectsMap = new ConcurrentSkipListMap<>(); //... myObjectsMap = myObje

1熱

1答えて

ExecutorService：出力が期待されない

出力を理解するのが難しいです。ここで私はエグゼキュータを作成し、Runnableタスクを1000回送信します。私はRunableの中にを追加しているので、期待される出力は1000ですが、実際の出力は503ではありません。 BV public class FutureTest { int count=0; public void testExecutor(){

-2熱

1答えて

オブジェクトではなくJava同期ロッククラスですか？

最近私はBruce Eckel（Thinking in Java）を読んでいて、いくつかの問題を発見しました。このクラスのオブジェクトではありません。このコードは上記のとおりです： public class Main { public static void main(String[] args) { Sync s = new Sync(); new Threa

3熱

1答えて

CompletableFutureとListenableFutureのコルーチン作成者に違いがあるのはなぜですか？ Kotlinのコルーチンのソースを調べる

ながら私は除いて（とほぼ同等の種類を考えても、私は、JDK 8 CompletableFuture public fun <T> future( context: CoroutineContext = DefaultDispatcher, start: CoroutineStart = CoroutineStart.DEFAULT, block: suspend Cor