- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 337 for enqueue (0.06 sec)
-
docs/fr/docs/history-design-future.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 4.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java
import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.regex.Pattern; import org.codelibs.fess.crawler.entity.AccessResultImpl; import org.codelibs.fess.crawler.entity.UrlQueueImpl; /** * @author shinsuke * */ public class MemoryDataHelper { protected volatile Map<String, Queue<UrlQueueImpl<Long>>> urlQueueMap = new HashMap<>();
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
final Queue<SearchLog> queue = searchLogQueue; searchLogQueue = new ConcurrentLinkedQueue<>(); processSearchLogQueue(queue); } if (!clickLogQueue.isEmpty()) { final Queue<ClickLog> queue = clickLogQueue; clickLogQueue = new ConcurrentLinkedQueue<>(); processClickLogQueue(queue); } }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 22 02:07:37 UTC 2024 - 21.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} } @Override public OpenSearchUrlQueue poll(final String sessionId) { final QueueHolder queueHolder = getQueueHolder(sessionId); final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue; final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue; OpenSearchUrlQueue urlQueue = waitingQueue.poll(); if (urlQueue != null) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/TestStringQueueGenerator.java
import java.util.List; import java.util.Queue; /** * Create queue of strings for tests. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public abstract class TestStringQueueGenerator implements TestQueueGenerator<String> { @Override public SampleElements<String> samples() { return new Strings(); } @Override public Queue<String> create(Object... elements) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ForwardingQueue.java
import java.util.NoSuchElementException; import java.util.Queue; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * A queue which forwards all its method calls to another queue. Subclasses should override one or * more methods to modify the behavior of the backing queue as desired per the <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 29 19:42:21 UTC 2021 - 4.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/ReferenceEntry.java
/** Returns the next entry in the access queue. */ ReferenceEntry<K, V> getNextInAccessQueue(); /** Sets the next entry in the access queue. */ void setNextInAccessQueue(ReferenceEntry<K, V> next); /** Returns the previous entry in the access queue. */ ReferenceEntry<K, V> getPreviousInAccessQueue(); /** Sets the previous entry in the access queue. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
/** * A queue of elements currently in the map, ordered by write time. Elements are added to the * tail of the queue on write. */ @GuardedBy("this") final Queue<ReferenceEntry<K, V>> writeQueue; /** * A queue of elements currently in the map, ordered by access time. Elements are added to the * tail of the queue on access (note that writes count as accesses).
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 149.2K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
*/ public final class Crawler { private final OkHttpClient client; private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>()); private final LinkedBlockingQueue<HttpUrl> queue = new LinkedBlockingQueue<>(); private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>(); public Crawler(OkHttpClient client) { this.client = client; }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 4.6K bytes - Viewed (0)