- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for coffee (0.15 sec)
-
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
*/ @CanIgnoreReturnValue // pushed down from class to method @Override public boolean add(E e) { return offer(e); } /** * Inserts the specified element into this priority queue. * * @param e the element to add * @return {@code true} (as specified by {@link Queue#offer}) * @throws ClassCastException if the specified element cannot be compared with elements currently
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/src/com/google/common/collect/ForwardingDeque.java
* methods of the delegate. For example, overriding {@link #add} alone <b>will not</b> change the * behavior of {@link #offer} which can lead to unexpected behavior. In this case, you should * override {@code offer} as well. * * <p><b>{@code default} method warning:</b> This class does <i>not</i> forward calls to {@code
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/TopKSelectorTest.java
for (int i = 0; i < 10; i++) { top.offer(i); } assertThat(top.topK()).isEmpty(); } public void testNoElementsOffered() { TopKSelector<Integer> top = TopKSelector.least(10); assertThat(top.topK()).isEmpty(); } public void testOfferedFewerThanK() { TopKSelector<Integer> top = TopKSelector.least(10); top.offer(3); top.offer(5); top.offer(2);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteArrayDataInput.java
import java.io.DataInput; import java.io.IOException; import javax.annotation.CheckForNull; /** * An extension of {@code DataInput} for reading from in-memory byte arrays; its methods offer * identical functionality but do not throw {@link IOException}. * * <p><b>Warning:</b> The caller is responsible for not attempting to read past the end of the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/ForwardingBlockingDeque.java
* to the methods of the delegate. For example, overriding {@link #add} alone <b>will not</b> change * the behaviour of {@link #offer} which can lead to unexpected behaviour. In this case, you should * override {@code offer} as well, either providing your own implementation, or delegating to the * provided {@code standardOffer} method. *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
private final Queue<E> delegate = Lists.newLinkedList(); public final Object mutex = new Integer(1); // something Serializable @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
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/EvictingQueueTest.java
EvictingQueue<String> queue = EvictingQueue.create(0); assertEquals(0, queue.size()); assertTrue(queue.add("hi")); assertEquals(0, queue.size()); assertTrue(queue.offer("hi")); assertEquals(0, queue.size()); assertFalse(queue.remove("hi")); assertEquals(0, queue.size()); try { queue.element(); fail();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
checkNotNull(subscribers); // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) { dispatching.set(true); try { Event nextEvent; while ((nextEvent = queueForThread.poll()) != null) {
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) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
SortedMap<Integer, AtomicInteger> replica = Maps.newTreeMap(); assertTrue("Empty heap should be OK", mmHeap.isIntact()); for (int i = 0; i < heapSize; i++) { int randomInt = random.nextInt(); mmHeap.offer(randomInt); insertIntoReplica(replica, randomInt); } assertIntact(mmHeap); assertEquals(heapSize, mmHeap.size()); int currentHeapSize = heapSize;
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-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
/** The queued items */ final E[] items; /** items index for next take, poll or remove */ int takeIndex; /** items index for next put, offer, or add. */ int putIndex; /** Number of items in the queue */ private int count; /* * Concurrency control uses the classic two-condition algorithm * found in any textbook. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 22.5K bytes - Viewed (0)