- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 810 for Spread (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
} private fun makeSynchronousCall(call: Call): Thread { val thread = Thread { try { call.execute() throw AssertionError() } catch (expected: IOException) { } } thread.start() return thread } private fun newRequest(url: String): Request = Request.Builder().url(url).build()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 15.8K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt
var ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) while (ms > 100) { Thread.sleep(100) if (javaNetSocket.isClosed) throw InterruptedIOException("socket closed") ms -= 100L } if (ms > 0L || ns > 0) { Thread.sleep(ms, ns.toInt()) } } override fun cancel() { delegate.cancel() } override fun close() {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 3.3K bytes - Click Count (0) -
impl/maven-core/src/test/java/org/apache/maven/internal/MultilineMessageHelperTest.java
msgs.add("* as @threadSafe to support parallel building. *"); msgs.add("* While this /may/ work fine, please look for plugin updates *"); msgs.add("* and/or request plugins be made thread-safe. *"); msgs.add("* If reporting an issue, report it against the plugin in *"); msgs.add("* question, not against maven-core *");
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3.5K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
} /** * Test: Thread-safe listener invocation during connection * Verifies that listeners can be added while connect() is executing */ @Test public void testConcurrentListenerInvocation() throws Exception { // This test verifies CopyOnWriteArrayList allows safe iteration assertTrue("OnConnectListener list should be thread-safe",Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 08:44:44 GMT 2025 - 17K bytes - Click Count (0) -
okhttp/src/commonTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabaseTest.kt
} } @Test fun threadIsInterruptedOnFirstRead() { Thread.currentThread().interrupt() try { val result = publicSuffixDatabase.getEffectiveTldPlusOne("squareup.com") assertThat(result).isEqualTo("squareup.com") } finally { assertThat(Thread.interrupted()).isTrue() } } @Test fun secondReadFailsSameAsFirst() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 22:00:49 GMT 2025 - 8.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
// Enqueueing the red task starts a thread because the head of the queue changed. redQueue.execute("red task") { log += "red:starting@${taskFaker.nanoTime}" taskFaker.sleep(100.µs) log += "red:finishing@${taskFaker.nanoTime}" } assertThat(taskFaker.executeCallCount).isEqualTo(1) // Enqueueing the blue task doesn't start a thread because the red one is still starting.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 23K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsule.java
return Optional.of(plexusContainer.getContainerRealm()); } @Override public void close() { try { plexusContainer.dispose(); } finally { Thread.currentThread().setContextClassLoader(previousClassLoader); } }
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Mar 24 14:09:05 GMT 2025 - 2.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/witness/WitnessRegistrationTest.java
assertTrue(seq2 > seq1); assertTrue(seq3 > seq2); } @Test void testHeartbeatUpdate() throws InterruptedException { long initialTime = registration.getLastHeartbeat(); Thread.sleep(50); // Ensure sufficient time difference registration.updateHeartbeat(); // After update, should not be expired with long timeout assertFalse(registration.isExpired(60000));
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 23 09:06:40 GMT 2025 - 5.1K bytes - Click Count (0) -
guava/src/com/google/common/io/Resources.java
* * @param from the URL to read from * @param to the output stream * @throws IOException if an I/O error occurs */ public static void copy(URL from, OutputStream to) throws IOException { asByteSource(from).copyTo(to); } /** * Returns a {@code URL} pointing to {@code resourceName} if the resource is found using the
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 7.4K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/s3/S3ClientTest.java
org.codelibs.core.timer.TimeoutTask accessTimeoutTask = null; if (accessTimeout != null) { accessTimeoutTarget = new org.codelibs.fess.crawler.client.AccessTimeoutTarget(Thread.currentThread()); accessTimeoutTask = org.codelibs.core.timer.TimeoutManager.getInstance() .addTimeoutTarget(accessTimeoutTarget, accessTimeout, false); }Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Dec 11 07:57:44 GMT 2025 - 20.5K bytes - Click Count (0)