- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 177 for task (0.12 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/BloomFilterTest.java
assertThat(exceptions).isEmpty(); } private static List<Throwable> runThreadsAndReturnExceptions(int numThreads, Runnable task) { List<Thread> threads = new ArrayList<>(numThreads); final List<Throwable> exceptions = new ArrayList<>(numThreads); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread(task); thread.setUncaughtExceptionHandler(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Nov 09 22:49:56 GMT 2023 - 21.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
AbstractService service, ScheduledExecutorService executor, Runnable task) { return new FutureAsCancellable( executor.scheduleWithFixedDelay(task, initialDelay, delay, unit)); } }; } /** * Returns a {@link Scheduler} that schedules the task using the {@link * ScheduledExecutorService#scheduleAtFixedRate} method. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
@CheckForNull private volatile InterruptibleTask<?> task; TrustedListenableFutureTask(Callable<V> callable) { this.task = new TrustedFutureInterruptibleTask(callable); } TrustedListenableFutureTask(AsyncCallable<V> callable) { this.task = new TrustedFutureInterruptibleAsyncTask(callable); } @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
* </pre> * * @return a list of {@code ListenableFuture} instances representing the tasks, in the same * sequential order as produced by the iterator for the given task list. If the operation did * not time out, each task will have completed. If it did time out, some of these tasks will * not have completed.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Sun Jun 20 10:45:35 GMT 2021 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
private static class FakeExecutor implements Executor { Queue<Runnable> tasks = Queues.newArrayDeque(); @Override public void execute(Runnable command) { tasks.add(command); } boolean hasNext() { return !tasks.isEmpty(); } void runNext() { assertTrue("expected at least one task to run", hasNext()); tasks.remove().run(); } void runAll() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
public class CacheLoaderTest extends TestCase { private static class QueuingExecutor implements Executor { private final Deque<Runnable> tasks = Queues.newArrayDeque(); @Override public void execute(Runnable task) { tasks.add(task); } private void runNext() { tasks.removeFirst().run(); } } public void testAsyncReload() throws Exception {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Aug 05 17:21:46 GMT 2022 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
* other {@code Future}, be {@linkplain #cancel cancelled}. * * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your * task cannot be implemented with {@link ListeningExecutorService}, the various {@link Futures} * utility methods, or {@link ListenableFutureTask}. Those APIs have less opportunity for developer
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 2.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* implemented as "no-effort". No interrupts or other attempts are made to stop threads executing * tasks. Second, the returned list will always be empty, as any submitted task is considered to * have started execution. This applies also to tasks given to {@code invokeAll} or {@code * invokeAny} which are pending serial execution, even the subset of the tasks that have not yet
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0)