Java BlockingQueueのマルチスレッドでの動きが分からない

Question

Javaの並列処理について質問です。
一日中悩んで色々考えたのですが動きがさっぱりわかりません。

        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();
    

JavaGoldSE11のソースコードの一部です。

実行結果と共に、私がわからない部分です。

参考書に載っている実行結果は
offer():1
offer():2
offer():3　//ここで容量が満タンになるのでofferメソッドは待機状態になる。
poll():0.24829714919143642
poll():0.9951008257323133 //要素が二つ削除される。
offer():3 **⇦なんで要素が3個??　上２行で二つ削除されてるからここは２と表示されるのでは？ **
poll():0.2502551360660312
poll():0.931467810599396
poll():0.08339082618949567
offer():2
以降続く...

私が実際した動作チェックでは

poll() : 0.17862616438523615　⇦なぜ最初から値が入っているのか謎　最初は少なくとも値を入れる処理が実行されるのでは？？
poll() : 0.07753396925462885
poll() : 0.15126249583873486
offer() : 2
offer() : 2
offer() : 3
poll() : 0.4808905765828154
poll() : 0.9636815724691447
poll() : 0.796135756517867
poll() : 0.20037575364874982　⇦なぜ四回連続で削除が成功してるのかも謎、三回目で要素がなくなってスレッドが待機状態になるのでは？？
offer() : 1
offer() : 2
offer() : 3

かなり沼にハマってます。どなたかご教授お願いします。

Answer 1

1'st-thread:

                    queue.offer(Math.random(), 2, TimeUnit.SECONDS); // 1-1
                    System.out.println("offer() : " + queue.size()); // 1-2

2'nd-thread:

                    double pNum = queue.poll(2, TimeUnit.SECONDS); // 2-1
                    System.out.println("poll() : " + pNum);        // 2-2

1-1 と 1-2 の間に 2-1 2-2 が割り込めば、poll() が先に出力されます。
十分起こりうるでしょう、offerされた途端に poll がデータを引き取れますから。

Comments

[YutaMatsuura715]

なるほどです。納得しました。
実際に私がEclipseで動作チェックしたものはコンソールで出力される前に既に
処理が始まっているから途中から実行結果が出てきて最初から値が削除される
部分からはじまっているように見えるのでしょうかね...