- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 403 for poll (0.02 sec)
-
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jul 24 20:12:35 UTC 2024 - 2.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
public void testPoll_empty() { assertNull("emptyQueue.poll() should return null", getQueue().poll()); expectUnchanged(); } @CollectionFeature.Require(SUPPORTS_REMOVE) @CollectionSize.Require(ONE) public void testPoll_size1() { assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll()); expectMissing(e0()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jul 24 20:12:35 UTC 2024 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
} catch (final UnsupportedEncodingException e) { throw new UnsupportedEncodingRuntimeException(e); } } protected Cipher pollEncryptoCipher() { Cipher cipher = encryptoQueue.poll(); if (cipher == null) { final SecretKeySpec sksSpec = new SecretKeySpec(key.getBytes(), algorithm); try { cipher = Cipher.getInstance(algorithm);
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8.1K bytes - Viewed (0) -
android/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;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 4.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* like [poll]. It is only usable within task faker tasks. */ private inner class TaskFakerBlockingQueue<T>( val delegate: BlockingQueue<T>, ) : AbstractQueue<T>(), BlockingQueue<T> { override val size: Int = delegate.size private var editCount = 0 override fun poll(): T = delegate.poll() override fun poll( timeout: Long, unit: TimeUnit,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} } @Override public OpenSearchUrlQueue poll(final String sessionId) { final QueueHolder queueHolder = getQueueHolder(sessionId); final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue; final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue; OpenSearchUrlQueue urlQueue = waitingQueue.poll(); if (urlQueue != null) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.4K 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Aug 19 20:50:58 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once) added += q.drainTo(buffer, numElements - added); if (added < numElements) { // not enough elements immediately available; will have to poll E e = q.poll(deadline - System.nanoTime(), NANOSECONDS); if (e == null) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java
} @Override public synchronized Map<String, Object> read() { while (!isFinished.get() && queue.isEmpty()) { addDocumentToQueue(); } return queue.poll(); } @Override public void close() { isFinished.set(true); queue.clear(); } public void setScrollSize(final int scrollSize) { this.scrollSize = scrollSize;
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 7.5K bytes - Viewed (0)