- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for execute (0.15 sec)
-
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
import java.util.Deque; import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; import java.util.logging.Level; import javax.annotation.CheckForNull; /** * Executor ensuring that all Runnables submitted are executed in order, using the provided * Executor, and sequentially such that no two will ever be running at the same time. * * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* guaranteed to execute. There is no guarantee, however, that listeners will be executed in the * order that they are added. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 6.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java
new IteratorOperation() { @Override public @Nullable Object execute(Iterator<?> iterator) { iterator.remove(); return null; } }; private static final IteratorOperation NEXT_METHOD = new IteratorOperation() { @Override public @Nullable Object execute(Iterator<?> iterator) { return iterator.next(); } };
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 21.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* calls to {@link Executor#execute `execute()`} that submitted those tasks had. * * <p>The executor uses {@code delegate} in order to {@link Executor#execute execute} each task in * turn, and does not create any threads of its own. * * <p>After execution begins on a thread from the {@code delegate} {@link Executor}, tasks are
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java
public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception // ListenableFuture's contract is that it will not throw unchecked exceptions, so log the bad // runnable and/or executor and swallow it. log.get() .log(
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 3.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java
new IteratorOperation() { @Override public @Nullable Object execute(Iterator<?> iterator) { iterator.remove(); return null; } }; private static final IteratorOperation NEXT_METHOD = new IteratorOperation() { @Override public @Nullable Object execute(Iterator<?> iterator) { return iterator.next(); } };
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 20.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
} } private static final class Listener { final Runnable command; final Executor executor; Listener(Runnable command, Executor executor) { this.command = checkNotNull(command); this.executor = checkNotNull(executor); } void execute() { try { executor.execute(command); } catch (RuntimeException e) { log.log( Level.SEVERE,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} }; for (int j = 0; j < 10; j++) { executor.execute(wrapper); } barrier.await(); // release the threads! barrier.await(); // wait for them all to complete assertEquals(1, task.get().intValue()); assertEquals(1, counter.get()); } executor.shutdown(); } @J2ktIncompatible @GwtIncompatible // blocking wait
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
public String get(long time, TimeUnit unit) { throw new CancellationException(); // BAD!! } @Override public void addListener(Runnable runnable, Executor executor) { executor.execute(runnable); } }; future.setFuture(badFuture); ExecutionException expected = getExpectingExecutionException(future);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
@CheckForNull Executor delegate; /** * Set before calling delegate.execute(); set to null once run, so that it can be GCed; this * object may live on after, if submitAsync returns an incomplete future. */ @CheckForNull Runnable task; /** Thread that called execute(). Set in execute, cleared when delegate.execute() returns. */ @CheckForNull @LazyInit Thread submitting;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0)