- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 512 for poll (0.02 seconds)
-
android/guava-tests/test/com/google/common/collect/ForwardingQueueTest.java
public boolean offer(T o) { return standardOffer(o); } @Override public @Nullable T peek() { return standardPeek(); } @Override public @Nullable T poll() { return standardPoll(); } } @AndroidIncompatible // test-suite builders public static Test suite() { TestSuite suite = new TestSuite();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 4.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* .maximumSize(1000) * .create(); * } * * <p>As a {@link Queue} it functions exactly as a {@link PriorityQueue}: its head element -- the * implicit target of the methods {@link #peek()}, {@link #poll()} and {@link #remove()} -- is * defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
@CanIgnoreReturnValue @Override public @Nullable E poll() { Monitor monitor = this.monitor; if (monitor.enterIf(notEmpty)) { try { return extract(); } finally { monitor.leave(); } } else { return null; } } @CanIgnoreReturnValue @Override public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (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.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 19K bytes - Click Count (0) -
android/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.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* .maximumSize(1000) * .create(); * } * * <p>As a {@link Queue} it functions exactly as a {@link PriorityQueue}: its head element -- the * implicit target of the methods {@link #peek()}, {@link #poll()} and {@link #remove()} -- is * defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
CLAUDE.md
- **CrawlerContext** (`CrawlerContext.java`): Execution context - `sessionId`, `status`, `accessCount`, `numOfThread`, `maxDepth`, `maxAccessCount` - **CrawlerThread** (`CrawlerThread.java`): Worker thread - Poll URL → Validate → Execute → Process → Queue children ### HTTP Client Architecture ``` SwitchableHttpClient (extends FaultTolerantClient) ├── Hc5HttpClient (default) - Apache HttpComponents 5.xCreated: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Mar 12 03:39:20 GMT 2026 - 8.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java
assertFalse(map.containsValue(valueOne)); assertThat(map.get(keyOne)).isNull(); assertEquals(1, map.size()); assertThat(segment.getKeyReferenceQueueForTesting().poll()).isNull(); } } } public void testDrainValueReferenceQueueOnWrite() { for (MapMaker maker : allWeakValueStrengthMakers()) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 36K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java
assertFalse(map.containsValue(valueOne)); assertThat(map.get(keyOne)).isNull(); assertEquals(1, map.size()); assertThat(segment.getKeyReferenceQueueForTesting().poll()).isNull(); } } } public void testDrainValueReferenceQueueOnWrite() { for (MapMaker maker : allWeakValueStrengthMakers()) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 36K bytes - Click Count (0)