BlockingQueue的drainTo()方法的线程安全性

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.TimeUnit;

public class DrainToExample {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue1 = new ArrayBlockingQueue<>(10);
        BlockingQueue<String> queue2 = new LinkedBlockingQueue<>();
        BlockingQueue<String> queue3 = new PriorityBlockingQueue<>();

        queue1.add("one");
        queue1.add("two");
        queue1.add("three");

        // 线程安全的drainTo()方法
        queue1.drainTo(queue2);
        queue1.drainTo(queue3);

        System.out.println("queue1: " + queue1);
        System.out.println("queue2: " + queue2);
        System.out.println("queue3: " + queue3);
    }
}