- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 168 for delaney (0.3 sec)
-
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private long delay; public NoOpDelayedService(long delay) { this.delay = delay; } @Override protected void doStart() { new Thread() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
cni/test/install_cni.go
retry.UntilSuccessOrFail(t, func() error { if err := checkResult(resultFile, expectedOutputFile); err == nil { // We should have waited for the delayed conf return fmt.Errorf("did not wait for valid config file") } return nil }, retry.Delay(time.Millisecond), retry.Timeout(time.Millisecond*250)) var destFilenm string if preConfFile != "" { destFilenm = preConfFile } else {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { TrustedListenableFutureTask<@Nullable Void> task = TrustedListenableFutureTask.create(command, null); ScheduledFuture<?> scheduled = delegate.schedule(task, delay, unit); return new ListenableScheduledTask<@Nullable Void>(task, scheduled); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertTrue(tryAcquireUninterruptibly(semaphore, LONG_DELAY_MS, MILLISECONDS)); assertTimeNotPassed(stopwatch, LONG_DELAY_MS); } public void testTryAcquireTimeoutNoInterruptNotExpired() { TimedSemaphore semaphore = TimedSemaphore.createWithDelay(20); semaphore.tryAcquireSuccessfully(LONG_DELAY_MS); assertNotInterrupted(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException, SampleException { MILLISECONDS.sleep(DELAY_MS); throw new SampleException(); } };
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String NUMBER_OF_PENDING_TASKS = "number_of_pending_tasks"; private static final String NUMBER_OF_IN_FLIGHT_FETCH = "number_of_in_flight_fetch"; private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards"; private static final String TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS = "task_max_waiting_in_queue_millis";
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
SMALL_DELAY_MS = SHORT_DELAY_MS * 5; MEDIUM_DELAY_MS = SHORT_DELAY_MS * 10; LONG_DELAY_MS = SHORT_DELAY_MS * 200; } /** * Returns a timeout in milliseconds to be used in tests that verify that operations block or time * out. */ long timeoutMillis() { return SHORT_DELAY_MS / 4; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
if len(c.delayedConfName) > 0 { // Delayed case // Write delayed CNI config file data, err := os.ReadFile(filepath.Join("testdata", c.delayedConfName)) if err != nil { t.Fatal(err) } err = os.WriteFile(filepath.Join(tempDir, c.delayedConfName), data, 0o644) if err != nil { t.Fatal(err) } t.Logf("delayed write to %v", filepath.Join(tempDir, c.delayedConfName))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* A value object that represents an absolute delay until a task should be invoked. * * @author Luke Sandberg * @since 11.0 */ protected static final class Schedule { private final long delay; private final TimeUnit unit; /** * @param delay the time from now to delay execution * @param unit the time unit of the delay parameter */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException, SampleException { MILLISECONDS.sleep(DELAY_MS); throw new SampleException(); } };
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0)