- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 372 for coffee (0.21 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 Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 19.5K bytes - Viewed (0) -
android/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 26 12:43:10 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
cmd/xl-storage-free-version.go
// free-version to track it for asynchronous // deletion via scanner. ver, err := x.getIdx(i) if err != nil { return err } if freeVersion, toFree := ver.ObjectV2.InitFreeVersion(fi); toFree { return x.addVersion(freeVersion) } return nil } return nil
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 3.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
private final Deque<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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
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 Apr 19 12:43:09 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 Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.2K bytes - Viewed (0) -
LICENSE
written offer to provide the Corresponding Source. This alternative is allowed only occasionally and noncommercially, and only if you received the object code with such an offer, in accord with subsection 6b. d) Convey the object code by offering access from a designated place (gratis or for a charge), and offer equivalent access to the
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 33.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
private static final class TestQueue<E> implements Queue<E> { private final Queue<E> delegate = Lists.newLinkedList(); public Object mutex; @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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} // BlockingQueue.take() tests public void testTakeWithNoWait() { Stopwatch stopwatch = Stopwatch.createStarted(); BlockingQueue<String> queue = new ArrayBlockingQueue<>(1); assertTrue(queue.offer("")); assertEquals("", takeUninterruptibly(queue)); assertTimeNotPassed(stopwatch, LONG_DELAY_MS); } public void testTakeNoInterrupt() { TimedTakeQueue queue = TimedTakeQueue.createWithDelay(20);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
docs/LICENSE
5. Downstream recipients. a. Offer from the Licensor -- Licensed Material. Every recipient of the Licensed Material automatically receives an offer from the Licensor to exercise the Licensed Rights under the terms and conditions of this Public License. b. No downstream restrictions. You may not offer or impose
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon May 10 16:50:06 GMT 2021 - 18.2K bytes - Viewed (0)