public final void submit(Queue<E> queue, E item) throws ConcurrentConveyorException {
        for (long idleCount = 0; !queue.offer(item); idleCount++) {
            SUBMIT_IDLER.idle(idleCount);
            checkDrainerGone();
            unparkDrainer();
            checkInterrupted();
        }
        for (long idleCount = 0; backpressure; idleCount++) {
            SUBMIT_IDLER.idle(idleCount);
            checkInterrupted();
        }
    }
@Test
    public void when_submitToGivenQueue_then_poll() {
        // when
        conveyor.submit(defaultQ, item1);

        // then
        assertSame(item1, defaultQ.poll());
    }