remove msg from the head of the queue . concode_field_sep int TIMEOUT_OCCURRED concode_elem_sep Runnable producerRunnable concode_elem_sep int mConsumerCounter concode_elem_sep int TIMEOUT_SECONDS concode_elem_sep BlockingQueue<E> mQueue concode_elem_sep int FAILURE_OCCURRED concode_elem_sep Runnable consumerRunnable concode_elem_sep String mValue concode_elem_sep QueueAdapter<Integer> mQueue concode_elem_sep int mProducerCounter concode_elem_sep int mMaxIterations concode_field_sep void run concode_elem_sep void run concode_elem_sep String getString concode_elem_sep SynchronizedQueueResult testQueue concode_elem_sep void put
E function ( ) { mConsumerCounter ++ ; E loc0 = mQueue . poll ( TIMEOUT_SECONDS , TimeUnit . SECONDS ) ; if ( loc0 == null ) throw new TimeoutException ( ) ; return loc0 ; }