Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 338 for queues (0.04 sec)

  1. android/guava/src/com/google/common/collect/Queues.java

       *
       * @param queue the queue to be wrapped in a synchronized view
       * @return a synchronized view of the specified queue
       * @since 14.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
        return Synchronized.queue(queue, null);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/Queues.java

       *
       * @param queue the queue to be wrapped in a synchronized view
       * @return a synchronized view of the specified queue
       * @since 14.0
       */
      @J2ktIncompatible // Synchronized
      public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
        return Synchronized.queue(queue, null);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/collect/QueuesTest.java

    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  4. 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)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        task.nextExecuteNanoTime = -1L
        val queue = task.queue!!
        queue.futureTasks.remove(task)
        readyQueues.remove(queue)
        queue.activeTask = task
        busyQueues.add(queue)
      }
    
      private fun afterRun(
        task: Task,
        delayNanos: Long,
        completedNormally: Boolean,
      ) {
        assertLockHeld()
    
        val queue = task.queue!!
        check(queue.activeTask === task)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. docs/bucket/replication/DESIGN.md

    ### Existing object replication
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  10. 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)
Back to top