java.util.concurrent

    0

    2答えて

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

    0

    3答えて

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

    0

    2答えて

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

    1

    1答えて

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

    1

    1答えて

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

    1

    1答えて

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

    -2

    1答えて

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

    3

    1答えて

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

    0

    1答えて

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