- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 1,052 for timeIt (0.04 seconds)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
private final AbstractFuture<?> future; private final long timeout; private final TimeUnit unit; private Exception exception; private volatile long startTime; private long timeSpentBlocked; TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) { this.future = future; this.timeout = timeout; this.unit = unit; } @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
} @Test @DisplayName("Test transition to HALF_OPEN after timeout") void testTransitionToHalfOpen() throws Exception { // Open the circuit circuitBreaker.tripBreaker(); assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState()); // Wait for timeout Thread.sleep(150); // Next call should transition to HALF_OPENCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.6K bytes - Click Count (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java
super.connect(new UnixSocketAddress(path), 0); } @Override public void connect(SocketAddress endpoint, int timeout) throws IOException { this.inetSocketAddress = (InetSocketAddress) endpoint; super.connect(new UnixSocketAddress(path), timeout); } @Override public InetAddress getInetAddress() { return inetSocketAddress.getAddress(); }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 1.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Platform.java
return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return future.blockingGet(timeout, unit); } private Platform() {}
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/Platform.java
return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return future.blockingGet(timeout, unit); } private Platform() {}
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/fscc/BasicFileInformationTest.java
}; for (long[] times : timeValues) { // Given FileBasicInfo info = new FileBasicInfo(times[0], // create time times[1], // last access time times[2], // last write time times[3], // change time TEST_ATTRIBUTES);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 13K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/DcerpcSecurityProviderTest.java
package jcifs.dcerpc; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.mockito.Mockito.doThrow; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.mockito.Mock; import org.mockito.MockitoAnnotations; import jcifs.dcerpc.ndr.NdrBuffer; class DcerpcSecurityProviderTest { @MockCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 2.5K bytes - Click Count (0) -
src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java
assertTrue(ex.getMessage().contains("directory must end with '/'")); verify(tree, times(1)).acquire(); verify(tree, times(1)).release(); // closed after failure } @Test @DisplayName("open(): invalid UNC without trailing backslash throws SmbException") void invalidUncThrows() throws Exception {
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
} catch (ExecutionException e) { rethrow(e); } throw new AssertionError("Unreachable"); } @Override public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { try { super.get(timeout, unit); } catch (ExecutionException e) { rethrow(e); } throw new AssertionError("Unreachable"); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java
public boolean isTerminated() { synchronized (lock) { return shutdown && runningTasks == 0; } } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { long nanos = unit.toNanos(timeout); synchronized (lock) { while (true) { if (shutdown && runningTasks == 0) { return true; } else if (nanos <= 0) { return false;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Dec 16 14:23:59 GMT 2025 - 3.4K bytes - Click Count (0)