- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 316 for queue (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 presentRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 18.9K bytes - Viewed (0) -
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)