- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 422 for _timeout (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
lastUnit = unit; return null; } // No need to test these methods as they are handled by WrappingExecutorServiceTest @Override public boolean awaitTermination(long timeout, TimeUnit unit) { throw new UnsupportedOperationException(); } @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 7.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
@Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { delegate.awaitRunning(timeout, unit); } /** * @since 15.0 */ @Override public final void awaitTerminated() { delegate.awaitTerminated(); } /** * @since 15.0 */ @Override public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 7.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* @throws CancellationException {@inheritDoc} */ @CanIgnoreReturnValue @Override public V get(long timeout, TimeUnit unit) throws InterruptedException, TimeoutException, ExecutionException { return sync.get(unit.toNanos(timeout)); } /* * Improve the documentation of when InterruptedException is thrown. Our
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (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(); }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 1.9K bytes - Viewed (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() {}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
} @CanIgnoreReturnValue @Override @ParametricNullness public V get(long timeout, TimeUnit unit) throws TimeoutException, InterruptedException, ExecutionException { long timeoutNanos = unit.toNanos(timeout); if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { return super.get(timeout, unit); } // Waiting 68 years should be enough for any program. return super.get(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java
// set fields via reflection setField(cmd, "fid", 0x1234); setField(cmd, "typeOfLock", (byte) 0x05); setField(cmd, "newOpLockLevel", (byte) 0x01); setField(cmd, "timeout", 3000L); // arrays of one lock and one unlock range LockingAndXRange lock = new LockingAndXRange(false); lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.1K bytes - Viewed (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"); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java
testRequest.setOverrideTimeout(timeout); assertEquals(timeout, testRequest.getOverrideTimeout()); } @Test @DisplayName("setOverrideTimeout should handle null value") void testSetOverrideTimeoutNull() { testRequest.setOverrideTimeout(5000); testRequest.setOverrideTimeout(null); assertNull(testRequest.getOverrideTimeout());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComTransaction.java
+ ",maxParameterCount=" + maxParameterCount + ",maxDataCount=" + maxDataCount + ",maxSetupCount=" + (int) maxSetupCount + ",flags=0x" + Hexdump.toHexString(flags, 2) + ",timeout=" + timeout + ",parameterCount=" + parameterCount + ",parameterOffset=" + parameterOffset + ",parameterDisplacement=" + parameterDisplacement + ",dataCount=" + dataCount
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 10.4K bytes - Viewed (0)