- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 157 for sheep (0.03 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} /** * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second. */ static class FakeStopwatch extends SleepingStopwatch { long instant = 0L; final List<String> events = new ArrayList<>(); @Override public long readMicros() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
} /** * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second. */ static class FakeStopwatch extends SleepingStopwatch { long instant = 0L; final List<String> events = new ArrayList<>(); @Override public long readMicros() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 21.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
} if (logger.isDebugEnabled()) { logger.debug("Waiting threads: {}", waitingThreadNames); } ThreadUtil.sleep(systemCpuCheckInterval); current = getSystemCpuPercent(); } } finally { waitingThreadNames.remove(threadName); } return true; }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 08:30:43 UTC 2025 - 36.6K bytes - Viewed (0) -
docs/smb3-features/05-rdma-smb-direct-design.md
long deadline = System.currentTimeMillis() + 5000; // 5 second timeout while (!rdmaConnection.canSend() && System.currentTimeMillis() < deadline) { try { Thread.sleep(10); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new IOException("Interrupted waiting for send credit", e); } }
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 35.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
public fun shutdownServer(shutdownServer: Boolean): Builder = apply { this.shutdownServer = shutdownServer } /** * Throttles the request reader and response writer to sleep for the given period after each * series of [bytesPerPeriod] bytes are transferred. Use this to simulate network behavior. */ public fun throttleBody( bytesPerPeriod: Long, period: Long,Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 17.8K bytes - Viewed (0) -
src/test/java/jcifs/netbios/LmhostsTest.java
// First read NbtAddress result = lmhosts.getByName("TESTHOST", mockContext); assertNotNull(result); // Modify file with a delay to ensure different lastModified time Thread.sleep(100); try (FileWriter writer = new FileWriter(lmhostsFile)) { writer.write("192.168.1.200 NEWHOST\n"); } // Should reload file and find new hostRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
numberOfSuggestDocs += res.getNumberOfSuggestDocs(); numberOfInputDocs += res.getNumberOfInputDocs(); queryLogs.clear(); Thread.sleep(requestInterval); } } deferred.resolve( new SuggestIndexResponse(numberOfSuggestDocs, numberOfInputDocs, errors, System.currentTimeMillis() - start));
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 34.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
}); } // Submit task to wipe key executor.submit(() -> { try { startLatch.await(); Thread.sleep(10); digest.secureWipeKey(); } catch (Exception e) { // Ignore } }); // Submit more tasks that try to verify dataRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 43.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
val request1ReceivedAt = System.currentTimeMillis() assertThat(server.takeRequest().headers["If-None-Match"]).isNull() // Hit that stored response. It's different, but Vary says it doesn't matter. Thread.sleep(10) // Make sure the timestamps are unique. val cacheHit = executeSynchronously( "/", "Accept-Language", "en-US", "Accept-Charset", "UTF-8", )
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 147.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
* application/vnd.ms-excel=excel<br> * application/vnd.ms-excel.sheet.2=excel<br> * application/vnd.ms-excel.sheet.3=excel<br> * application/vnd.ms-excel.sheet.4=excel<br> * application/vnd.ms-excel.workspace.3=excel<br> * application/vnd.ms-excel.workspace.4=excel<br> * application/vnd.openxmlformats-officedocument.spreadsheetml.sheet=excel<br> * application/vnd.ms-powerpoint=powerpoint<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)