- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 226 for runnable (0.07 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { Preconditions.checkNotNull(task, "task must not be null!"); Preconditions.checkNotNull(result, "result must not be null!"); return delegate.submit(task, result); } @Override public ListenableFuture<?> submit(Runnable task) { Preconditions.checkNotNull(task, "task must not be null!");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { Preconditions.checkNotNull(task, "task must not be null!"); Preconditions.checkNotNull(result, "result must not be null!"); return delegate.submit(task, result); } @Override public ListenableFuture<?> submit(Runnable task) { Preconditions.checkNotNull(task, "task must not be null!");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
Runnable runnable, @ParametricNullness V result) { return new ListenableFutureTask<>(runnable, result); } ListenableFutureTask(Callable<V> callable) { super(callable); } ListenableFutureTask(Runnable runnable, @ParametricNullness V result) { super(runnable, result); } @Override public void addListener(Runnable listener, Executor exec) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
*/ @Override ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit); /** * Duration-based overload of {@link #schedule(Runnable, long, TimeUnit)}. * * @since 29.0 */ @J2ktIncompatible default ListenableScheduledFuture<?> schedule(Runnable command, Duration delay) { return schedule(command, toNanosSaturated(delay), TimeUnit.NANOSECONDS); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Feb 11 17:30:04 UTC 2025 - 3.6K bytes - Viewed (0) -
guava-testlib/test/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilderTest.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Jan 25 16:19:30 UTC 2025 - 2.3K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/sereq/AdminSereqAction.java
* * @param runnable optional runnable to execute before rendering (can be null) * @return HTML response for the search request list page */ private HtmlResponse asListHtml(final Runnable runnable) { if (runnable != null) { runnable.run(); } return asHtml(path_AdminSereq_AdminSereqJsp).useForm(UploadForm.class);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* otherwise-concurrent GC cycle. */ private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState> implements Executor, Runnable { /** * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run * or queued. */ @Nullable ExecutionSequencer sequencer; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
val taskRunner: TaskRunner = TaskRunner( object : TaskRunner.Backend { override fun execute( taskRunner: TaskRunner, runnable: Runnable, ) { taskRunner.assertLockHeld() val queuedTask = RunnableSerialTask(runnable) serialTaskQueue += queuedTask executeCallCount++ isParallel = serialTaskQueue.size > 1 }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Feb 11 17:30:04 UTC 2025 - 2.1K bytes - Viewed (0)