Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 403 for poll (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

                    return;
                }
                response = r;
    
                executeCallbacks = new ArrayList<>(doneCallbacks.size());
                Consumer<RESPONSE> callback;
                while ((callback = doneCallbacks.poll()) != null) {
                    executeCallbacks.add(callback);
                }
            }
            if (executeCallbacks.size() > 0) {
                try {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top