- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 501 for Runnable (0.1 seconds)
-
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; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return true; } @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMailDeliveryDepartmentCreator.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 7K bytes - Click Count (0) -
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!");
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (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!");
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 11.3K bytes - Click Count (0) -
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.3K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testSameThreadScheduledExecutorWithException() throws InterruptedException { Runnable runnable = () -> { throw new RuntimeException("Oh no!"); }; Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); assertThrows(ExecutionException.class, future::get); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
} public void testSameThreadScheduledExecutorWithException() throws InterruptedException { Runnable runnable = () -> { throw new RuntimeException("Oh no!"); }; Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); assertThrows(ExecutionException.class, future::get); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
*/ @J2ktIncompatible @GwtIncompatible // concurrency static Thread newThread(String name, Runnable runnable) { checkNotNull(name); checkNotNull(runnable); // TODO(b/139726489): Confirm that null is impossible here. Thread result = requireNonNull(platformThreadFactory().newThread(runnable)); try { result.setName(name); } catch (SecurityException e) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0)