- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 353 for queues (0.07 sec)
-
src/main/java/org/codelibs/fess/util/QueryStringBuilder.java
*/ public QueryStringBuilder() { // Default constructor } /** * Quotes a string value if it contains spaces. * Multi-word values are wrapped in double quotes with internal quotes replaced by spaces. * * @param value the string value to quote * @return the quoted string if it contains spaces, otherwise the original value */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 12.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
* Get the value for the key 'logging.search.max.queue.size'. <br> * The value is, e.g. 10000 <br> * comment: Maximum queue size for search logging. * @return The value of found property. (NotNull: if not found, exception but basically no way) */ String getLoggingSearchMaxQueueSize(); /** * Get the value for the key 'logging.search.max.queue.size' as {@link Integer}. <br>
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 525.7K bytes - Viewed (2) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
protected void finalize() { finalizerRan.countDown(); } }); await(finalizerRan); awaitClear(ref); // Hope to catch some stragglers queued up behind our finalizable object System.runFinalization(); } private static RuntimeException formatRuntimeException(String format, Object... args) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
protected void finalize() { finalizerRan.countDown(); } }); await(finalizerRan); awaitClear(ref); // Hope to catch some stragglers queued up behind our finalizable object System.runFinalization(); } private static RuntimeException formatRuntimeException(String format, Object... args) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/EvictingQueueTest.java
assertTrue(queue.add("one")); assertTrue(queue.add("two")); assertTrue(queue.add("three")); assertEquals("one", queue.element()); assertEquals("one", queue.peek()); assertEquals(3, queue.size()); assertEquals(0, queue.remainingCapacity()); assertTrue(queue.add("four")); assertEquals("two", queue.element()); assertEquals("two", queue.peek()); assertEquals(3, queue.size());Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 6.7K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/entity/UrlQueueImplTest.java
UrlQueueImpl<Long> queue = new UrlQueueImpl<>(); assertNotNull(queue); assertNull(queue.getId()); assertNull(queue.getSessionId()); assertNull(queue.getMethod()); assertNull(queue.getUrl()); assertNull(queue.getMetaData()); assertNull(queue.getEncoding()); assertNull(queue.getParentUrl()); assertNull(queue.getDepth());
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 13 13:29:22 UTC 2025 - 9.1K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/util/OpenSearchCrawlerConfig.java
this.filterIndex = filterIndex; } /** * Returns the number of queue shards. * @return The number of queue shards. */ public int getQueueShards() { return queueShards; } /** * Sets the number of queue shards. * @param queueShards The number of queue shards. */ public void setQueueShards(final int queueShards) {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 5.4K bytes - Viewed (10) -
CHANGELOG/CHANGELOG-1.25.md
- Sometimes, the scheduler incorrectly placed a pod in the "unschedulable" queue instead of the "backoff" queue. This happened when some plugin previously declared the pod as "unschedulable" and then in a later attempt encounters some other error. Scheduling of that pod then got delayed by up to five minutes, after which periodic flushing moved the pod back into the "active" queue. ([#120334](https://github.com/kubernetes/kubernetes/pull/120334), [@pohly](https://github.com/pohly))...
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Mon May 06 09:23:20 UTC 2024 - 419.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt
startNs = queue.taskRunner.backend.nanoTime() log(task, queue, "starting") } var completedNormally = false try { val result = block() completedNormally = true return result } finally { if (loggingEnabled) { val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs if (completedNormally) { log(task, queue, "finished run in ${formatDuration(elapsedNs)}")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(6, queue.size()); assertEquals(8, queue.capacity()); checkUnbounded(queue); checkNatural(queue); } public void testCreation_maximumSize_withContents() { MinMaxPriorityQueue<Integer> queue = rawtypeToWildcard(MinMaxPriorityQueue.maximumSize(42)).create(NUMBERS); assertEquals(6, queue.size()); assertEquals(11, queue.capacity()); assertEquals(42, queue.maximumSize);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 36.1K bytes - Viewed (0)