- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 1,108 for figure (0.04 seconds)
-
guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/TestPlatform.java
// There is no thread interruption in GWT, so there's nothing to do. } static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return future.get(0, SECONDS); } catch (InterruptedException e) { throw new AssertionError(); } catch (TimeoutException e) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
SettableFuture<String> future = SettableFuture.create(); FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false); runNInterruptsTest(times, future, interruptReporter); } private static void runTimedInterruptsTest(int times) throws InterruptedException, ExecutionException, TimeoutException { SettableFuture<String> future = SettableFuture.create();
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) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
Callable<String> callable = () -> expected; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertThat(future.get()).isEqualTo(expected); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable_exception() throws Exception { Exception expected = new IllegalArgumentException();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
Callable<String> callable = () -> expected; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertThat(future.get()).isEqualTo(expected); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable_exception() throws Exception { Exception expected = new IllegalArgumentException();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 4K bytes - Click Count (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
SettableFuture<@Nullable Void> future = SettableFuture.create(); Object unused = new Object() { @SuppressWarnings({"removal", "Finalize"}) // b/487687332 @Override protected void finalize() { future.set(null); } }; unused = null; // Hint to the JIT that unused is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
static <V extends @Nullable Object, X extends Exception> V getChecked( Future<V> future, Class<X> exceptionClass) throws X { return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass); } /** Implementation of {@link Futures#getChecked(Future, Class)}. */ @CanIgnoreReturnValue @VisibleForTesting @ParametricNullness static <V extends @Nullable Object, X extends Exception> V getChecked(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 10.2K bytes - Click Count (0) -
src/archive/tar/strconv_test.go
var p parser got := p.parseNumeric([]byte(v.in)) ok := (p.err == nil) if ok != v.ok { if v.ok { t.Errorf("parseNumeric(%q): got parsing failure, want success", v.in) } else { t.Errorf("parseNumeric(%q): got parsing success, want failure", v.in) } } if ok && got != v.want { t.Errorf("parseNumeric(%q): got %d, want %d", v.in, got, v.want) } } }
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Sep 11 17:52:43 GMT 2025 - 15K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return amInterruptible ? future.get(timeoutDuration, timeoutUnit) : getUninterruptibly(future, timeoutDuration, timeoutUnit); } catch (InterruptedException e) { future.cancel(true); throw e; } catch (ExecutionException e) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 9.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/failureurl/ApiAdminFailureurlAction.java
.status(ApiResult.Status.OK) .result()); } // GET /api/admin/failureurl/log/{id} /** * Retrieves a specific failure URL log by ID. * * @param id the failure URL log ID * @return JSON response containing the failure URL log */ @Execute public JsonResponse<ApiResult> get$log(final String id) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 6.2K bytes - Click Count (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/RecordedRequest.kt
body: Buffer, sequenceNumber: Int, failure: IOException?, method: String?, path: String?, handshake: Handshake?, requestUrl: HttpUrl?, ) { this.requestLine = requestLine this.headers = headers this.chunkSizes = chunkSizes this.bodySize = bodySize this.body = body this.sequenceNumber = sequenceNumber this.failure = failure this.method = method this.path = pathCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.1K bytes - Click Count (0)