java.util.concurrent

0熱

2答えて

CopyOnWriteArrayList（cowal）

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

java java.util.concurrent 2017-12-18

---

0熱

3答えて

ScheduledThreadPoolExecutor並行タスク

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

java java.util.concurrent 2017-12-24

---

0熱

2答えて

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

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

salesforce mule java.util.concurrent 2017-12-25

---

1熱

1答えて

Javaのネストされたキュー

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

java multithreading concurrency java.util.concurrent 2017-12-27

---

1熱

1答えて

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

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

java concurrency java.util.concurrent sortedmap concurrentskiplistmap 2017-09-20

---

1熱

1答えて

ExecutorService：出力が期待されない

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

java runnable executorservice java.util.concurrent 2017-11-10

---

-2熱

1答えて

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

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

java multithreading concurrency synchronized java.util.concurrent 2017-11-12

---

3熱

1答えて

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

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

kotlin guava java.util.concurrent coroutine kotlinx.coroutines 2017-11-22

---

0熱

1答えて

ConcurrentHashMapで「マージ」メソッドを正しく使用する方法は？

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

java java.util.concurrent concurrenthashmap 2017-10-13

---