- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 227 for Kqueue (0.04 sec)
-
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) -
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) -
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) -
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) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)