Многопточность и очередь пример

public class Stream1 extends Thread {
 
 
    @Override
    public void run() {
        try {
            int cnt = 0;
 
            for (int i = 0; i < QueueTest.arr.length; i++) {
                QueueTest.drop.put(QueueTest.arr[i]);
                if (++cnt < 3) {
                    Thread.sleep(2000);
                }
            }
            QueueTest.drop.put(QueueTest.DONE);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
 
    }
 
}

public class Stream2 extends Thread {
 
 
    @Override
    public void run() {
 
        try {
            String msg = null;
 
            while (!((msg = QueueTest.drop.take()).equals(QueueTest.DONE))) {
                System.out.println(msg);
            }
        } catch (InterruptedException e) {
            System.err.println(e.getMessage());
        }
    }
 
}

public class QueueTest {
    static String DONE = "DONE";
 
    static BlockingQueue<String> drop = new ArrayBlockingQueue<>(1, true);
    static String[] arr = {"1", "2", "3", "4"};
 
}

public class Main {
 
 
    public static void main(String[] args) {
 
        new Stream1().start();
        new Stream2().start();
 
 
    }
 
 
}