- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for Moll (0.44 sec)
-
android/guava/src/com/google/common/collect/ForwardingQueue.java
public boolean offer(@ParametricNullness E o) { return delegate().offer(o); } @CanIgnoreReturnValue // TODO(cpovirk): Consider removing this? @Override @CheckForNull public E poll() { return delegate().poll(); } @CanIgnoreReturnValue @Override @ParametricNullness public E remove() { return delegate().remove(); } @Override @CheckForNull public E peek() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jun 29 19:42:21 GMT 2021 - 4.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedQueueTest.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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/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 May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 13 14:30:51 GMT 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
sendRequest(methodName, arguments); Thread.sleep(DUE_DILIGENCE_MILLIS); assertEquals(true, invokeMethod("hasQueuedThread", this)); assertNull(responseQueue.poll()); } /** * Causes this thread to call the named method, and asserts that this thread thereby waits on the * given condition-like object. The lock-like object must have a method equivalent to {@link
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java
assertFalse(map.containsValue(valueOne)); assertNull(map.get(keyOne)); assertEquals(1, map.size()); assertNull(segment.getKeyReferenceQueueForTesting().poll()); } } } public void testDrainValueReferenceQueueOnWrite() { for (MapMaker maker : allWeakValueStrengthMakers()) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 35.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java
assertFalse(map.containsValue(valueOne)); assertNull(map.get(keyOne)); assertEquals(1, map.size()); assertNull(segment.getKeyReferenceQueueForTesting().poll()); } } } public void testDrainValueReferenceQueueOnWrite() { for (MapMaker maker : allWeakValueStrengthMakers()) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 35.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} } void checkEmpty(BlockingQueue<?> q) { try { assertTrue(q.isEmpty()); assertEquals(0, q.size()); assertNull(q.peek()); assertNull(q.poll()); assertNull(q.poll(0, MILLISECONDS)); assertEquals("[]", q.toString()); assertTrue(Arrays.equals(q.toArray(), new Object[0])); assertFalse(q.iterator().hasNext()); try { q.element();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
public void execute() { synchronized (runnables) { if (executed) { return; } executed = true; } while (!runnables.isEmpty()) { runnables.poll().execute(); } } private static class RunnableExecutorPair { final Runnable runnable; final Executor executor; RunnableExecutorPair(Runnable runnable, Executor executor) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
.removalListener(listener) .ticker(ticker) .build(); cache.put(1, 1); ticker.advance(10, TimeUnit.MINUTES); cache.invalidateAll(); assertThat(listener.poll().getCause()).isEqualTo(RemovalCause.EXPIRED); } private void runRemovalScheduler( LoadingCache<String, Integer> cache, CountingRemovalListener<String, Integer> removalListener,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Aug 05 17:21:46 GMT 2022 - 18.7K bytes - Viewed (0)