E function ( ) { E loc0 = mQueue . poll ( TIMEOUT_SECONDS , TimeUnit . SECONDS ) ; if ( loc0 == null ) throw new TimeoutException ( ) ; mConsumerCounter ++ ; return loc0 ; }
remove msg from the head of the queue . concode_field_sep int TIMEOUT_OCCURRED concode_elem_sep Runnable mProducerRunnable concode_elem_sep BlockingQueue<E> mQueue concode_elem_sep boolean diagnosticsEnabled concode_elem_sep int mProducerCounter concode_elem_sep int mMaxIterations concode_elem_sep Runnable mConsumerRunnable concode_elem_sep int mConsumerCounter concode_elem_sep int TIMEOUT_SECONDS concode_elem_sep Thread mConsumer concode_elem_sep String mTestName concode_elem_sep int FAILURE_OCCURRED concode_elem_sep String mValue concode_elem_sep Thread mProducer concode_elem_sep QueueAdapter<Integer> mQueue concode_field_sep SynchronizedQueueResult checkResults concode_elem_sep int size concode_elem_sep void interruptThreads concode_elem_sep void joinThreads concode_elem_sep void run concode_elem_sep void run concode_elem_sep void createThreads concode_elem_sep void startThreads concode_elem_sep String getString concode_elem_sep SynchronizedQueueResult testQueue concode_elem_sep void put