- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 569 for Wait (0.03 seconds)
-
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
public void testCircuitResetsAfterTimeout() throws Exception { // Open the circuit circuitBreaker.trip(); assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN"); // Wait for reset timeout Thread.sleep(1100); // Execute successful operation - should transition to HALF_OPEN then potentially CLOSED String result = circuitBreaker.executeWithCircuitBreaker(() -> "success");
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 23.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
* for successful and unsuccessful computations, respectively. * </p> * * <p> * The Deferred class uses a CountDownLatch to allow you to wait for the computation to complete. * The resolve and reject methods decrement the CountDownLatch, allowing the getResponse method * to return the result of the computation. * </p> *
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Fri Jul 04 14:00:23 GMT 2025 - 7.8K bytes - Click Count (0) -
.github/dependabot.yml
version: 2 updates: # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more # easily import the generated PRs into our internal repo. # - package-ecosystem: "maven" # directory: "/" # schedule: # interval: "weekly" # groups: # dependencies: # applies-to: version-updates # patterns: # - "*" # - package-ecosystem: "maven" # directory: "/android" # schedule:
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jan 06 17:34:37 GMT 2026 - 995 bytes - Click Count (0) -
internal/dsync/drwmutex.go
5*time.Second, ) } func log(format string, data ...any) { if dsyncLog { console.Printf(format, data...) } } const ( // dRWMutexAcquireTimeout - default tolerance limit to wait for lock acquisition before. drwMutexAcquireTimeout = 1 * time.Second // 1 second. // dRWMutexRefreshTimeout - default timeout for the refresh call drwMutexRefreshCallTimeout = 5 * time.Second
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
throws TimeoutException, ExecutionException { SettableFuture<String> future = SettableFuture.create(); future.set(RESULT); /* * getUninterruptibly should call the timed get method once with a * wait of 0 seconds (and it should succeed, since the result is already * available). */ assertThat(getUninterruptibly(future, 0, SECONDS)).isEqualTo(RESULT); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0) -
docs/releasing.md
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 19 15:45:22 GMT 2025 - 1.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryCacheEntryTest.java
public void testExpiration() { // Set a very short max age entry.setMaxAge(100); // 100ms assertFalse(entry.isExpired()); assertFalse(entry.needsRefresh()); // Wait for expiration try { Thread.sleep(150); } catch (InterruptedException e) { // Ignore } assertTrue(entry.isExpired());
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 01:47:47 GMT 2025 - 8.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} public void testAwaitTimeoutMultiInterruptExpired() { /* * We don't "need" to schedule a countDown() call at all here, but by doing * so, we come the closest we can to testing that the wait time is * appropriately decreased on each progressive await() call. */ TimedLatch latch = new TimedLatch(/* countdownInMillis= */ LONG_DELAY_MS); repeatedlyInterruptTestThread(tearDownStack);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
internal/lsync/lrwmutex_test.go
cdone := make(chan bool) for range numReaders { go parallelReader(context.Background(), m, clocked, cunlock, cdone) } // Wait for all parallel RLock()s to succeed. for range numReaders { <-clocked } for range numReaders { cunlock <- true } // Wait for the goroutines to finish. for range numReaders { <-cdone } } // Borrowed from rwmutex_test.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
apache-maven/src/assembly/maven/bin/mvnenc.cmd
@REM @REM JAVA_HOME (Optional) Points to a Java installation. @REM MAVEN_BATCH_ECHO (Optional) Set to 'on' to enable the echoing of the batch commands. @REM MAVEN_BATCH_PAUSE (Optional) set to 'on' to wait for a key stroke before ending. @REM MAVEN_OPTS (Optional) Java runtime options used when Maven is executed. @REM MAVEN_SKIP_RC (Optional) Flag to disable loading of mavenrc files.
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 18 11:01:21 GMT 2024 - 1.7K bytes - Click Count (0)