Method run

storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:123–126

(Runnable producer, Runnable consumer, JCQueue queue)

    }

    private void run(Runnable producer, Runnable consumer, JCQueue queue)
        throws InterruptedException {
        run(producer, consumer, queue, 20, PRODUCER_NUM);
    }

    private void run(Runnable producer, Runnable consumer, JCQueue queue, int sleepMs, int producerNum)
        throws InterruptedException {