Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 51 for directExecutor (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
     *         .transform((closer, result) -> result.get("userName"), directExecutor())
     *         .catching(DBException.class, e -> "no user", directExecutor())
     *         .finishToFuture();
     * }
     *
     * In this example, when the {@code userName} {@link Future} is done, the transaction and the query
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 13:51:27 UTC 2025
    - 96.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

       * ListenableFuture<Integer> faultTolerantFuture = Futures.catching(
       *     fetchCounterFuture, FetchException.class, x -> 0, directExecutor());
       * }
       *
       * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
       * the warnings the {@link MoreExecutors#directExecutor} documentation.
       *
       * @param input the primary input {@code Future}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * Inappropriate {@code directExecutor} usage can cause problems, and these problems can be
       * difficult to reproduce because they depend on timing. For example:
       *
       * <ul>
       *   <li>When a {@code ListenableFuture} listener is registered to run under {@code
       *       directExecutor}, the listener can execute in any of three possible threads:
       *       <ol>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.Executors.newCachedThreadPool;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.concurrent.Callable;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

    import static com.google.common.util.concurrent.Futures.immediateFuture;
    import static com.google.common.util.concurrent.Futures.transformAsync;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static org.junit.Assert.assertThrows;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.Executors.newCachedThreadPool;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.concurrent.Callable;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Executor;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Executor;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

     * <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
     * thrown by {@linkplain MoreExecutors#directExecutor direct execution}) will be caught and logged.
     *
     * @author Nishant Thakkar
     * @author Sven Mawson
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class ExecutionList {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
Back to top