Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 161 for queued (0.04 seconds)

  1. android/guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java

        // Now we find the task in our Executor and explicitly activate it.
        List<Runnable> tasks = executor.getTasks();
        assertEquals("One event dispatch task should be queued.", 1, tasks.size());
    
        tasks.get(0).run();
    
        assertEquals("One event should be delivered.", 1, events.size());
        assertWithMessage("Correct string should be delivered.").that(events.get(0)).isEqualTo(EVENT);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 2.4K bytes
    - Click Count (0)
  2. 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. */
    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)
  3. 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. */
    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)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        /**
         * QueueHolder holds the waiting and crawling queues.
         */
        protected static class QueueHolder {
            /**
             * Constructs a new QueueHolder.
             */
            public QueueHolder() {
                // Default constructor
            }
    
            /**
             * The queue for URLs waiting to be crawled.
             */
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  5. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        WeakReference<Object> ref = createWeakReferenceWithFinalizer(finalizerRan);
    
        await(finalizerRan);
        awaitClear(ref);
    
        // Hope to catch some stragglers queued up behind our finalizable object
        System.runFinalization();
      }
    
      private static WeakReference<Object> createWeakReferenceWithFinalizer(
          CountDownLatch finalizerRan) {
        Object referent = new Object();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  6. guava-testlib/src/com/google/common/testing/GcFinalization.java

        WeakReference<Object> ref = createWeakReferenceWithFinalizer(finalizerRan);
    
        await(finalizerRan);
        awaitClear(ref);
    
        // Hope to catch some stragglers queued up behind our finalizable object
        System.runFinalization();
      }
    
      private static WeakReference<Object> createWeakReferenceWithFinalizer(
          CountDownLatch finalizerRan) {
        Object referent = new Object();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  7. src/builtin/builtin.go

    //   - Pointer to array: the number of elements in *v (even if v is nil).
    //   - Slice, or map: the number of elements in v; if v is nil, len(v) is zero.
    //   - String: the number of bytes in v.
    //   - Channel: the number of elements queued (unread) in the channel buffer;
    //     if v is nil, len(v) is zero.
    //
    // For some arguments, such as a string literal or a simple array expression, the
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

            return true;
        }
    
        /**
         * Stores child URLs from the given set into the crawling queue for future processing.
         * This method filters out blank URLs and increments the depth for child URLs.
         *
         * @param urlQueue the parent URL queue item
         * @param childUrlSet the set of child URLs to be queued for crawling
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 11 09:47:03 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  9. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

    /**
     * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders
     * elements FIFO (first-in-first-out). The head of the queue is that element that has been
     * on the queue the longest time. The tail of the queue is that element that has been on
     * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue
     * retrieval operations obtain elements at the head of the queue.
    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)
  10. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

                CopyUtil.copy(in, out);
                asyncImport(fileName, tempFile);
    
                if (logger.isInfoEnabled()) {
                    logger.info("Backup file uploaded successfully and queued for import: fileName={}, tempFile={}", fileName,
                            tempFile.getAbsolutePath());
                }
            } catch (final IOException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Nov 24 02:07:40 GMT 2025
    - 32.1K bytes
    - Click Count (0)
Back to Top