Class ConcurrentQTest

    • Constructor Detail

      • ConcurrentQTest

        public ConcurrentQTest()
    • Method Detail

      • setUp

        public void setUp()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • tearDown

        public void tearDown()
                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testFailure

        public void testFailure()
                         throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testSequentialExecution

        public void testSequentialExecution()
                                     throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testParallelExecution

        public void testParallelExecution()
                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testAddIterator

        public void testAddIterator()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testListenerCallback

        public void testListenerCallback()
                                  throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitForLimitedTime

        public void testWaitForLimitedTime()
                                    throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitUntilEmptyAndThreadsIdle

        public void testWaitUntilEmptyAndThreadsIdle()
                                              throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • testWaitWithTimeOutOnEmptyQueueDoesntBlock

        public void testWaitWithTimeOutOnEmptyQueueDoesntBlock()
                                                        throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • testWaitForeverOnEmptyQueueDoesntBlock

        public void testWaitForeverOnEmptyQueueDoesntBlock()
                                                    throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • testCancelExecution

        public void testCancelExecution()
                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testMaxThreads

        public void testMaxThreads()
                            throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • testWaitUntilDoneOnEmptyQueue

        public void testWaitUntilDoneOnEmptyQueue()
                                           throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitUntilDone

        public void testWaitUntilDone()
                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitUntilDoneWithExceptionBeforeWait

        public void testWaitUntilDoneWithExceptionBeforeWait()
                                                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitUntilDoneWithExceptionWhileWaiting

        public void testWaitUntilDoneWithExceptionWhileWaiting()
                                                        throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitForNextResult

        public void testWaitForNextResult()
                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitForNextResultExceptionDoesNotStop

        public void testWaitForNextResultExceptionDoesNotStop()
                                                       throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testWaitUntilDoneIsCancellable

        public void testWaitUntilDoneIsCancellable()
                                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • testOffer

        public void testOffer()
                       throws java.lang.Exception
        Throws:
        java.lang.Exception