- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 464 for Runnable (0.07 sec)
-
android/guava/src/com/google/common/util/concurrent/Callables.java
boolean unused = trySetName(oldName, currentThread); } } }; } /** * Wraps the given runnable such that for the duration of {@link Runnable#run} the thread that is * running with have the given name. * * @param task The Runnable to wrap * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor( Runnable runnable, @ParametricNullness T value) { return TrustedListenableFutureTask.create(runnable, value); } /** * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0) */ @CanIgnoreReturnValue // TODO(kak): consider removing this
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor( Runnable runnable, @ParametricNullness T value) { return TrustedListenableFutureTask.create(runnable, value); } /** * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0) */ @CanIgnoreReturnValue // TODO(kak): consider removing this
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 3K bytes - Viewed (0) -
src/test/java/jcifs/tests/ConcurrencyTest.java
List<MutiThreadTestCase> runnables = new ArrayList<>(); for ( int i = 0; i < 20; i++ ) { runnables.add(new MutiThreadTestCase()); } runMultiTestCase(runnables, 60); } private void runMultiTestCase ( List<? extends MultiTestCase> testcases, int timeoutSecs ) throws InterruptedException { for ( Runnable r : testcases ) { this.executor.submit(r);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 14 17:40:50 UTC 2021 - 17.6K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AnonymousClassesFilteringTest.kt
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
} @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(runnable); checkNotNull(timeoutUnit); try { runnable.run(); } catch (Exception e) { // sneaky checked exception throw new UncheckedExecutionException(e); } catch (Error e) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override public void shutdown() { delegate().shutdown(); } @Override @CanIgnoreReturnValue public List<Runnable> shutdownNow() { return delegate().shutdownNow(); } @Override public void execute(Runnable command) { delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
@Override ListenableScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit); /** @since 15.0 (previously returned ScheduledFuture) */ @Override ListenableScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 2.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java
} @CanIgnoreReturnValue static <T extends Throwable> T assertThrows( Class<T> expectedThrowable, ThrowingRunnable runnable) { return doAssertThrows( expectedThrowable, () -> { runnable.run(); return null; }, /* userPassedSupplier= */ false); } private static <T extends Throwable> T doAssertThrows(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 19:10:20 UTC 2024 - 6.3K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/ReflectionFreeAssertThrows.java
} @CanIgnoreReturnValue static <T extends Throwable> T assertThrows( Class<T> expectedThrowable, ThrowingRunnable runnable) { return doAssertThrows( expectedThrowable, () -> { runnable.run(); return null; }, /* userPassedSupplier= */ false); } private static <T extends Throwable> T doAssertThrows(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 22 13:49:09 UTC 2024 - 6.3K bytes - Viewed (0)