- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 57 for Moll (0.12 sec)
-
android/guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertEquals(0, queue.size()); try { queue.element(); fail(); } catch (NoSuchElementException expected) { } assertNull(queue.peek()); assertNull(queue.poll()); try { queue.remove(); fail(); } catch (NoSuchElementException expected) { } } public void testRemainingCapacity_maxSize0() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
clearValueReferenceQueue(); } } void clearKeyReferenceQueue() { while (keyReferenceQueue.poll() != null) {} } void clearValueReferenceQueue() { while (valueReferenceQueue.poll() != null) {} } // recency queue, shared by expiration and eviction /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
// If even the first one wasn't there, clean up so that the next test doesn't see an element. producerThread.cancel(true); producer.doneProducing.await(); if (drained == 0) { q.poll(); // not necessarily there if producer was interrupted } } } public void testZeroElements() throws Exception { for (BlockingQueue<Object> q : blockingQueues()) { testZeroElements(q);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java
} } } /** * Implementation of the InvertedMinMaxPriorityQueue which forwards all calls to a * MinMaxPriorityQueue, except poll, which is forwarded to pollMax. That way we can benchmark * pollMax using the same code that benchmarks poll. */ static final class InvertedMinMaxPriorityQueue<T> extends ForwardingQueue<T> { MinMaxPriorityQueue<T> mmHeap;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 19.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(1, (int) mmHeap.peek()); assertEquals(1, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(2, (int) mmHeap.peek()); assertEquals(2, (int) mmHeap.poll()); assertEquals(3, (int) mmHeap.peekLast()); assertEquals(3, (int) mmHeap.peek()); assertEquals(3, (int) mmHeap.poll()); assertNull(mmHeap.peekLast()); assertNull(mmHeap.peek());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java
} @Override public E take() throws InterruptedException { return delegate().take(); } @Override @CheckForNull public E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override public int drainTo(Collection<? super E> c) { return delegate().drainTo(c); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/base/internal/Finalizer.java
/** * Starts the Finalizer thread. FinalizableReferenceQueue calls this method reflectively. * * @param finalizableReferenceClass FinalizableReference.class. * @param queue a reference queue that the thread will poll. * @param frqReference a phantom reference to the FinalizableReferenceQueue, which will be queued * either when the FinalizableReferenceQueue is no longer referenced anywhere, or when its * close() method is called.
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Aug 23 12:54:09 GMT 2023 - 9.4K bytes - Viewed (0)