Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 182 for Queues (0.19 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

        /**
         * Deletes all URL queues.
         */
        void deleteAll();
    
        /**
         * Offers all URL queues.
         *
         * @param sessionId The session ID.
         * @param newUrlQueueList The list of new URL queues.
         */
        void offerAll(String sessionId, List<QUEUE> newUrlQueueList);
    
        /**
         * Polls a URL queue.
         *
         * @param sessionId The session ID.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top