- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 389 for Spread (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/distributed/DESIGN.md
- In this algorithm, we also make sure that we spread the drives out evenly. MinIO server expands ellipses passed as arguments. Here is a sample expansion to demonstrate the process. ``` minio server http://host{1...2}/export{1...8} ``` Expected expansion ```Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Feb 26 09:25:50 GMT 2025 - 8K bytes - Click Count (2) -
api/maven-api-xml/src/main/java/org/apache/maven/api/xml/XmlService.java
@Nonnull public static XmlNode read(InputStream input, @Nullable InputLocationBuilder locationBuilder) throws XMLStreamException { return getService().doRead(input, locationBuilder); } /** * Reads an XML node from a reader. */ @Nonnull public static XmlNode read(Reader reader) throws XMLStreamException { return read(reader, null); } /**Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Apr 03 13:33:59 GMT 2025 - 9.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
} } abstract val path: Any /** * Reads the public suffix list treating the operation as uninterruptible. We always want to read * the list otherwise we'll be left in a bad state. If the thread was interrupted prior to this * operation, it will be re-interrupted after the list is read. */ private fun readTheListUninterruptibly() { var interrupted = false try { while (true) { try {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 3.6K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) { int nRead = 0; while (remaining > 0 && (nRead = reader.read(buffer, bufIndex, remaining)) != -1) { bufIndex += nRead; remaining -= nRead; } if (nRead == -1) { // we reached EOF return new String(buffer, 0, bufIndex); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 5.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java
@Override public Thread newThread(Runnable r) { Thread thread = new Thread(r); thread.setName(THREAD_NAME); thread.setPriority(THREAD_PRIORITY); thread.setDaemon(THREAD_DAEMON); thread.setUncaughtExceptionHandler(UNCAUGHT_EXCEPTION_HANDLER); return thread; } }; Thread thread =Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 7.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java
@Override public String toString() { assertTrue(Thread.holdsLock(mutex)); return delegate.toString(); } @Override public boolean equals(@Nullable Object o) { assertTrue(Thread.holdsLock(mutex)); return delegate.equals(o); } @Override public int hashCode() { assertTrue(Thread.holdsLock(mutex)); return delegate.hashCode(); }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 4.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 7.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
} } void stopInterrupting() { shouldStop = true; } } /** Interrupts the current thread after sleeping for the specified delay. */ static void requestInterruptIn(long time, TimeUnit unit) { checkNotNull(unit); Thread interruptee = Thread.currentThread(); new Thread( new Runnable() { @Override public void run() { try {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 4.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 7.8K bytes - Click Count (0)