Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 512 for poll (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

      @Override
      public @Nullable E poll() {
        Monitor monitor = this.monitor;
        monitor.enter();
        try {
          return q.poll();
        } finally {
          monitor.leave();
        }
      }
    
      @CanIgnoreReturnValue // pushed down from class to method
      @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
    - 19K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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.x
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Mar 12 03:39:20 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top