Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 316 for queue (0.26 sec)

  1. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/MethodMetaData.java

        public MethodMetaData getOverriddenMethod() {
            LinkedList<ClassMetaData> queue = new LinkedList<ClassMetaData>();
            queue.add(ownerClass.getSuperClass());
            queue.addAll(ownerClass.getInterfaces());
    
            String overrideSignature = getOverrideSignature();
    
            while (!queue.isEmpty()) {
                ClassMetaData cl = queue.removeFirst();
                if (cl == null) {
                    continue;
                }
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 4.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 3));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 3));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/crypto/CachedCipher.java

         */
        protected String charsetName = CoreLibConstants.UTF_8;
    
        /**
         * The queue of ciphers for encryption.
         */
        protected Queue<Cipher> encryptoQueue = new ConcurrentLinkedQueue<>();
    
        /**
         * The queue of ciphers for decryption.
         */
        protected Queue<Cipher> decryptoQueue = new ConcurrentLinkedQueue<>();
    
        /**
         * Encrypts the given data.
         *
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/base/internal/Finalizer.java

          ReferenceQueue<Object> queue,
          PhantomReference<Object> frqReference) {
        this.queue = queue;
    
        this.finalizableReferenceClassReference = new WeakReference<>(finalizableReferenceClass);
    
        // Keep track of the FRQ that started us so we know when to stop.
        this.frqReference = frqReference;
      }
    
      /** Loops continuously, pulling references off the queue and cleaning them up. */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

            }
            log(logHelper, LogType.FINISHED_THREAD, crawlerContext);
        }
    
        /**
         * Adds sitemaps from robots.txt to the crawling queue.
         * @param urlQueue The URL queue to add sitemaps to.
         */
        protected void addSitemapsFromRobotsTxt(final UrlQueue<?> urlQueue) {
            final String[] sitemaps = crawlerContext.removeSitemaps();
            if (sitemaps != null) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/FinalizableReferenceQueue.java

        startFinalizer = getStartFinalizer(finalizer);
      }
    
      /** The actual reference queue that our background thread will poll. */
      final ReferenceQueue<Object> queue;
    
      final PhantomReference<Object> frqRef;
    
      /** Whether or not the background thread started successfully. */
      final boolean threadStarted;
    
      /** Constructs a new queue. */
      public FinalizableReferenceQueue() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/testers/AbstractQueueTester.java

    package com.google.common.collect.testing.testers;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.collect.testing.AbstractCollectionTester;
    import java.util.Queue;
    import org.junit.Ignore;
    
    /**
     * Base class for queue collection tests.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @Ignore("test runners must not instantiate and run this directly, only via suites we build")
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * formally, removes an element {@code e} such that {@code o.equals(e)}, if this queue contains
       * one or more such elements. Returns {@code true} if and only if this queue contained the
       * specified element (or equivalently, if this queue changed as a result of the call).
       *
       * @param o element to be removed from this queue, if present
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/FinalizablePhantomReference.java

      /**
       * Constructs a new finalizable phantom reference.
       *
       * @param referent to phantom reference
       * @param queue that should finalize the referent
       */
      protected FinalizablePhantomReference(@Nullable T referent, FinalizableReferenceQueue queue) {
        super(referent, queue.queue);
        queue.cleanUp();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
Back to top