Java マルチスレッドの実行結果についての疑問店

Question

LinkedBlockingQueueのマルチスレッドでの挙動について

以下のコードでなぜ出力結果の６行目がoffer():3になるのでしょうか？

        BlockingQueue<Double> queue = new LinkedBlockingQueue<>(3);
        new Thread(() -> { 
            while(true){
                try {
                    queue.offer(Math.random(), 2, TimeUnit.SECONDS);
                    System.out.println("offer() : " + queue.size());
                } catch (InterruptedException e) { e.printStackTrace(); }
            }
        }).start();

        new Thread(() -> { 
            while(true){
                try {
                    double pNum = queue.poll(2, TimeUnit.SECONDS);
                    System.out.println("poll() : " + pNum);
                } catch (InterruptedException e) { e.printStackTrace(); }
            }
        }).start();

offer():1
offer():2
offer():3　
poll():0.24829714919143642
poll():0.9951008257323133
offer():3 ⇦なんで要素が3個??　上２行で二つ削除されてるからここは２と表示されるのでは？
poll():0.2502551360660312
poll():0.931467810599396
poll():0.08339082618949567
offer():2
以降続く...

いろんなパターンを考えてみましたが、どう頑張っても6行目が３になるパターンが分りません。
どのようなときに３になるのでしょうか？

Comments

[jimbe]

さすがに「疑問店」というは直されたほうがよいのでは。

Answer 1

複数スレッドを非同期に動かしているので、何がどのような順番で実行されるかは、はっきりと断定することはできません。
例えば、pollの「出力」の前に、offerの「実行」がなされた可能性があります。つまり、

offer():1
offer():2
offer():3　
poll():0.24829714919143642
//このタイミングで、キューへの追加のみ行われ、出力が待ちの状態
poll():0.9951008257323133 
offer():3 

非同期処理を実行している以上、「こうなるはず」というのは容易には決定できないことをご注意ください。

Comments

[YutaMatsuura715]

ありがとうございます