- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 182 for Queues (0.19 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java
* <li>Deleting URL queues associated with a session.</li> * <li>Deleting all URL queues.</li> * <li>Offering a list of URLs to the queue, ensuring duplicates are not added.</li> * <li>Polling (retrieving and removing) a URL from the queue.</li> * <li>Saving the session (currently a no-op).</li> * <li>Checking if a URL has already been visited.</li> * <li>Generating URL queues from a previous session's access results.</li>
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 9.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt
/** Returns the delay in nanoseconds until the next execution, or -1L to not reschedule. */ abstract fun runOnce(): Long internal fun initQueue(queue: TaskQueue) { if (this.queue === queue) return check(this.queue === null) { "task is in multiple queues" } this.queue = queue } override fun toString(): String = name
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java
super(); } /** * Clears all URL queues and session data. */ public void clear() { urlQueueMap.clear(); sessionMap.clear(); } /** * Returns the URL queue for the specified session ID. * Creates a new queue if one doesn't exist. * @param sessionId the session ID * @return the URL queue for the session */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread * for its work; in practice a set of queues may share a set of threads to save resources. */ class TaskQueue internal constructor( internal val taskRunner: TaskRunner, internal val name: String, ) { internal var shutdown = false
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 7.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java
import java.util.Queue; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Creates queues, containing sample elements, to be tested. * * @author Jared Levy */ @GwtCompatible @NullMarked public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> { @Override Queue<E> create(Object... elements);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java
import java.util.Queue; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Creates queues, containing sample elements, to be tested. * * @author Jared Levy */ @GwtCompatible @NullMarked public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> { @Override Queue<E> create(Object... elements);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.1K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ @SuppressWarnings("ThreadLocalUsage") // Each Dispatcher needs its own state. private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return new ArrayDeque<>(); } };
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EvictingQueue.java
import java.util.Collection; import java.util.Queue; /** * A non-blocking queue which automatically evicts elements from the head of the queue when * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e., * cyclic buffer or ring buffer). *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
if ok { for i, queue := range config.QueueList { // Remove ARN not found queues, because we previously allowed // adding unexpected entries into the config. // // With newer config disallowing changing / turning off // notification targets without removing ARN in notification // configuration we won't see this problem anymore. if reflect.DeepEqual(queue.ARN, arnErr.ARN) && i < len(config.QueueList) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.1K bytes - Viewed (0)