Searched refs:reachedBarrier (Results 1 – 1 of 1) sorted by relevance
144 final AtomicBoolean reachedBarrier = new AtomicBoolean(false); in processMessagesNonBlocking() local146 reachedBarrier.set(true); in processMessagesNonBlocking()151 return processMessagesInternal(num, barrierRunnable) + (reachedBarrier.get() ? -1 : 0); in processMessagesNonBlocking()