Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 227 for Kqueue (0.04 sec)

  1. docker-buildx.sh

    	# go build -trimpath to build the binary.
    	export GOOS=$os
    	export GOARCH=$arch
    	export MINIO_RELEASE=RELEASE
    	LDFLAGS=$(go run buildscripts/gen-ldflags.go)
    	go build -tags kqueue -trimpath --ldflags "${LDFLAGS}" -o ./minio-${arch}.${release}
    	minisign -qQSm ./minio-${arch}.${release} -s "$CRED_DIR/minisign.key" <"$CRED_DIR/minisign-passphrase"
    
    	sha256sum_str=$(sha256sum <./minio-${arch}.${release})
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Oct 19 08:22:05 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  2. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  3. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 18K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        /**
         * QueueHolder holds the waiting and crawling queues.
         */
        protected static class QueueHolder {
            /**
             * Constructs a new QueueHolder.
             */
            public QueueHolder() {
                // Default constructor
            }
    
            /**
             * The queue for URLs waiting to be crawled.
             */
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

        /**
         * Adds a URL to the queue.
         *
         * @param sessionId The session ID.
         * @param url The URL.
         */
        void add(String sessionId, String url);
    
        /**
         * Inserts a URL queue.
         *
         * @param urlQueue The URL queue.
         */
        void insert(QUEUE urlQueue);
    
        /**
         * Deletes a URL queue.
         *
         * @param sessionId The session ID.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 3));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(THROWING_EVENT);
        queue.enqueue(incrementingEvent(counters, listener, 3));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

         */
        public synchronized void addUrlQueueList(final String sessionId, final Queue<UrlQueueImpl<Long>> urlQueueList) {
            final Queue<UrlQueueImpl<Long>> uqList = getUrlQueueList(sessionId);
            uqList.addAll(urlQueueList);
            urlQueueMap.put(sessionId, uqList);
        }
    
        /**
         * Removes the URL queue for the specified session ID.
         * @param sessionId the session ID
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  10. 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: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
Back to top