- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 161 for queued (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)