Searched refs:mLinkedBlockingQueue (Results 1 – 1 of 1) sorted by relevance
41 private LinkedBlockingQueue<T> mLinkedBlockingQueue; field in TestValueCountConsumer45 mLinkedBlockingQueue = new LinkedBlockingQueue<>(); in TestValueCountConsumer()51 mLinkedBlockingQueue.offer(value); in accept()66 value = mLinkedBlockingQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in waitAndGet()80 T value = mLinkedBlockingQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in waitAndGetAllValues()92 mLinkedBlockingQueue.clear(); in clearQueue()