- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 219 for Queues (0.02 sec)
-
src/main/resources/fess_label_de.properties
labels.suggestWord=Wort vorschlagen labels.targetLabel=Label labels.term=Begriff labels.fields=Felder labels.ex_q=Erweiterte Abfrage labels.oldPassword=Aktuelles Passwort labels.newPassword=Neues Passwort labels.confirmNewPassword=Neues Passwort (bestätigen) labels.menu_system=System labels.menu_wizard=Assistent labels.menu_crawl_config=Allgemein labels.menu_scheduler_config=Scheduler labels.menu_dashboard_config=Dashboard
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 46.9K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/exec/Crawler.java
/** Atomic flag indicating whether the crawler is currently running. */ private static AtomicBoolean running = new AtomicBoolean(false); /** Thread-safe queue for collecting error messages during crawling operations. */ private static Queue<String> errors = new ConcurrentLinkedQueue<>(); /** Injected search engine client for OpenSearch operations. */ @ResourceRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 31.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
import com.google.common.collect.testing.features.CollectionFeature; import com.google.common.collect.testing.features.CollectionSize; import org.junit.Ignore; /** * A generic JUnit test which tests {@code poll()} operations on a queue. Can't be invoked directly; * please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 2.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
final long elapsed = (System.nanoTime() - start) / 1000000; assertTrue("file:// URLs should not be delayed", elapsed < 50); } /** * Test that null URL queue is handled gracefully */ public void test_nullUrlQueue() { final HostIntervalController controller = new HostIntervalController(); controller.delayMillisBeforeProcessing = 1000L;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/TestingRemovalListeners.java
static <K, V> CountingRemovalListener<K, V> countingRemovalListener() { return new CountingRemovalListener<>(); } /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */ @GwtIncompatible // ConcurrentLinkedQueue static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>> implements RemovalListener<K, V> { @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 3.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java
import com.google.common.collect.testing.features.CollectionFeature; import com.google.common.collect.testing.features.CollectionSize; import org.junit.Ignore; /** * A generic JUnit test which tests {@code poll()} operations on a queue. Can't be invoked directly; * please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 2.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterators.java
return !queue.isEmpty(); } @Override @ParametricNullness public T next() { IndexedIterator<T> nextIndexed = queue.remove(); PeekingIterator<T> nextIter = nextIndexed.iterator; T next = nextIter.next(); if (nextIter.hasNext()) { queue.add(nextIndexed); } return next; } }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 16 12:42:11 UTC 2025 - 51.4K bytes - Viewed (0) -
src/main/java/jcifs/util/ResourceManager.java
ResourceHolder(String resourceId, AutoCloseable resource, ReferenceQueue<AutoCloseable> queue) { this.resourceId = resourceId; this.resourceType = resource.getClass().getSimpleName(); this.resourceRef = new WeakReference<>(resource); this.phantomRef = new PhantomReference<>(resource, queue); this.creationTime = System.currentTimeMillis();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java
import com.google.common.collect.testing.features.CollectionSize; import java.util.NoSuchElementException; import org.junit.Ignore; /** * A generic JUnit test which tests {@code remove()} operations on a queue. Can't be invoked * directly; please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/TestingRemovalListeners.java
static <K, V> CountingRemovalListener<K, V> countingRemovalListener() { return new CountingRemovalListener<>(); } /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */ @GwtIncompatible // ConcurrentLinkedQueue static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>> implements RemovalListener<K, V> { @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 3.1K bytes - Viewed (0)