- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 556 for sleeps (0.18 sec)
-
.github/workflows/smokeshow.yml
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Fri Aug 15 21:44:06 UTC 2025 - 1.8K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/ThreadUtil.java
} /** * Causes the currently executing thread to sleep (temporarily cease execution) for the specified number of milliseconds. * * @param millis * the length of time to sleep in milliseconds * @throws InterruptedRuntimeException * if any thread has interrupted the current thread. */ public static void sleep(final long millis) { if (millis < 1L) { return;
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 2.3K bytes - Viewed (0) -
cmd/callhome.go
return } // callhome running on a different node. // sleep for some time and try again. duration := max(time.Duration(r.Float64()*float64(globalCallhomeConfig.FrequencyDur())), // Make sure to sleep at least a second to avoid high CPU ticks. time.Second) time.Sleep(duration) } }() } func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
val request = Request(server.url("/")) val response1 = client.newCall(request).execute() assertThat(response1.body.string()).isEqualTo("a") // Give the thread pool a chance to evict. Thread.sleep(500) val response2 = client.newCall(request).execute() assertThat(response2.body.string()).isEqualTo("b") assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 12.2K bytes - Viewed (1) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
} private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong()) } catch (e: InterruptedException) { Thread.currentThread().interrupt() } } private fun interruptLater(delayMillis: Int) { val toInterrupt = Thread.currentThread() val interruptingCow = Thread { sleep(delayMillis) toInterrupt.interrupt()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
List<Integer> result = addSupplier.get(); assertEquals(Integer.valueOf(0), result.get(0)); assertEquals(Integer.valueOf(1), result.get(1)); } @J2ktIncompatible @GwtIncompatible // Thread.sleep @SuppressWarnings("DoNotCall") public void testMemoizeWithExpiration_longTimeUnit() throws InterruptedException { CountingSupplier countingSupplier = new CountingSupplier();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 17.9K bytes - Viewed (0) -
api/maven-api-core/src/test/java/org/apache/maven/api/MonotonicClockTest.java
void testMonotonicBehavior() throws InterruptedException { Instant first = MonotonicClock.now(); Thread.sleep(10); // Small delay Instant second = MonotonicClock.now(); Thread.sleep(10); // Small delay Instant third = MonotonicClock.now(); assertTrue(first.isBefore(second), "Time should progress forward between measurements");
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jan 15 06:28:29 UTC 2025 - 5.8K bytes - Viewed (0) -
docs/bucket/replication/setup_2site_existing_replication.sh
--remote-bucket http://minio:minio123@127.0.0.1:9004/bucket remote_arn=$(./mc replicate ls sitea/bucket --json | jq -r .rule.Destination.Bucket) sleep 1 ./mc replicate resync start sitea/bucket/ --remote-bucket "${remote_arn}" sleep 30s ## sleep for 30s idea is that we give 300ms per object. ./mc ls -r --versions sitea/bucket >/tmp/sitea.txt ./mc ls -r --versions siteb/bucket >/tmp/siteb.txt
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 5.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java
Thread.sleep(5); // Small delay to ensure different timestamps Smb2LeaseKey key2 = limitedManager.requestLease("/share/file2.txt", Smb2LeaseState.SMB2_LEASE_READ_CACHING); Thread.sleep(5); // Small delay to ensure different timestamps
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 13.2K bytes - Viewed (0) -
docs/site-replication/run-multi-site-minio-idp.sh
## add foobar-g group with foobar ./mc admin group add minio2 foobar-g foobar ./mc admin policy attach minio1 consoleAdmin --user=foobar sleep 5 ./mc admin user info minio2 foobar ./mc admin group info minio1 foobar-g ./mc admin policy create minio1 rw ./docs/site-replication/rw.json sleep 5 ./mc admin policy info minio2 rw >/dev/null 2>&1 ./mc admin replicate status minio1 ## Add a new empty site
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 24 08:03:58 UTC 2024 - 12.1K bytes - Viewed (0)