public void run() {
                try {
                    for (int i = 0; i < interations; ++i) {
                        T t;
                        do {
                            t = source.poll(1,  TimeUnit.NANOSECONDS);
                        }
                        while (t == null);

                        sink.put(t);
                    }
                }
                catch (InterruptedException e) {
                    throw new AssertionError(e);
                }
            }
This test demonstrates a race where a producer wins the CAS and writes
null to blocked, only to have the consumer overwrite its change. To have
it fail consistently, add a 1ms sleep (or a breakpoint) to
parkUntilNext(), just before the soBlocked(Thread.currentThread()). If it
hits the race writing to the blocked field, one of the threads will spin
forever in spinWaitForUnblock().
jctools-core/src/test/java/org/jctools/queues/QueueSanityTestMpscBlockingConsumerArrayExtended.java