BlockingQueue: put () и isEmpty () не работают вместе?

Я хотел бы иметь SynchronousQueue, в который я вставляю элементы из одного потока с помощью put(), поэтому ввод блокируется до тех пор, пока элемент не будет взят в другом потоке.

В другом потоке я выполняю множество вычислений и время от времени хочу проверять, доступен ли уже элемент, и использовать его. Но кажется, что isEmpty() всегда возвращает истину, даже если другой поток ожидает вызова put().

Как такое возможно? Вот пример кода:

@Test
public void testQueue() throws InterruptedException {
    final BlockingQueue<Integer> queue = new SynchronousQueue<Integer>();

    Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
            while (true) {
                if (!queue.isEmpty()) {
                    try {
                        queue.take();
                        System.out.println("taken!");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                // do useful computations here (busy wait)
            }
        }
    });
    t.start();

    queue.put(1234);
    // this point is never reached!
    System.out.println("hello");
}

Обновлено: Ни isEmpty (), ни peek () не работают, нужно использовать poll (). Спасибо!