- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ExecutionList (0.2 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* @author Sven Mawson * @since 1.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class ExecutionList { /** Logger to log exceptions caught when running runnables. */ private static final LazyLogger log = new LazyLogger(ExecutionList.class); /** * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link * RunnableExecutorPair#next} field.
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) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; /** * Unit tests for {@link ExecutionList}. * * @author Nishant Thakkar * @author Sven Mawson */ public class ExecutionListTest extends TestCase { private final ExecutionList list = new ExecutionList(); public void testRunOnPopulatedList() throws Exception { Executor exec = Executors.newCachedThreadPool();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
// such as BoundedQueueExecutorService to allow extends but it would be nice to make it final to // avoid unintended usage. // The execution list to hold our listeners. private final ExecutionList executionList = new ExecutionList(); /** * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code * Callable}. * * @param callable the callable task * @since 10.0 */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
Executors.newCachedThreadPool(threadFactory); private final Executor adapterExecutor; // The execution list to hold our listeners. private final ExecutionList executionList = new ExecutionList(); // This allows us to only start up a thread waiting on the delegate future when the first // listener is added. private final AtomicBoolean hasListeners = new AtomicBoolean(false);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; /** * Unit tests for {@link ExecutionList}. * * @author Nishant Thakkar * @author Sven Mawson */ public class ExecutionListTest extends TestCase { private final ExecutionList list = new ExecutionList(); public void testRunOnPopulatedList() throws Exception { Executor exec = Executors.newCachedThreadPool();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
/** Synchronization control for AbstractFutures. */ private final Sync<V> sync = new Sync<V>(); // The execution list to hold our executors. private final ExecutionList executionList = new ExecutionList(); /** Constructor for use by subclasses. */ protected OldAbstractFuture() {} /* * Improve the documentation of when InterruptedException is thrown. Our
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
/** Synchronization control for AbstractFutures. */ private final Sync<V> sync = new Sync<V>(); // The execution list to hold our executors. private final ExecutionList executionList = new ExecutionList(); /** Constructor for use by subclasses. */ protected OldAbstractFuture() {} /* * Improve the documentation of when InterruptedException is thrown. Our
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
Object getImpl(); } enum Impl { NEW { @Override ExecutionListWrapper newExecutionList() { return new ExecutionListWrapper() { final ExecutionList list = new ExecutionList(); @Override public void add(Runnable runnable, Executor executor) { list.add(runnable, executor); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 20.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
Object getImpl(); } enum Impl { NEW { @Override ExecutionListWrapper newExecutionList() { return new ExecutionListWrapper() { final ExecutionList list = new ExecutionList(); @Override public void add(Runnable runnable, Executor executor) { list.add(runnable, executor); } @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
*/ @J2ktIncompatible @GwtIncompatible // reflection public void testTransformExceptionRemainsMemoized() throws Throwable { // We need to test with two input futures since ExecutionList.execute // doesn't catch Errors and we cannot depend on the order that our // transformations run. (So it is possible that the Error being thrown // could prevent our second transformations from running).
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0)