- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 69 for directExecutor (2.6 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.JdkFutureAdapters.listenInPoolThread; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.Executors.newCachedThreadPool; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.testing.ClassSanityTester;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
android/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>
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/Futures.java
* ListenableFuture<Integer> faultTolerantFuture = Futures.catching( * fetchCounterFuture, FetchException.class, x -> 0, directExecutor()); * }</pre> * * <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}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
import static com.google.common.base.StandardSystemProperty.OS_NAME; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.Arrays.asList; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.collect.ImmutableMap;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import com.google.caliper.AfterExperiment; import com.google.caliper.BeforeExperiment; import com.google.caliper.Benchmark; import com.google.caliper.Param; import com.google.caliper.api.Footprint;
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/ListenableFutureTaskTest.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static org.junit.Assert.assertThrows; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java
* MoreExecutors#directExecutor}. */ @VmOptions({"-Xms12g", "-Xmx12g", "-d64"}) public class MoreExecutorsDirectExecutorBenchmark { enum Impl { EXECUTOR_SERVICE { @Override Executor executor() { return newDirectExecutorService(); } }, EXECUTOR { @Override Executor executor() { return directExecutor(); } };
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java
* MoreExecutors#directExecutor}. */ @VmOptions({"-Xms12g", "-Xmx12g", "-d64"}) public class MoreExecutorsDirectExecutorBenchmark { enum Impl { EXECUTOR_SERVICE { @Override Executor executor() { return newDirectExecutorService(); } }, EXECUTOR { @Override Executor executor() { return directExecutor(); } };
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
* License for the specific language governing permissions and limitations under * the License. */ package com.google.common.util.concurrent.testing; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.util.concurrent.ListenableFuture; import java.util.concurrent.CountDownLatch;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.Futures.transform; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import com.google.common.base.Function; import java.lang.reflect.UndeclaredThrowableException; /** * Unit tests for {@link Futures#transform(ListenableFuture, Function, Executor)}. *
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Jun 28 16:27:15 GMT 2018 - 1.9K bytes - Viewed (0)