- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for newSingleThreadExecutor (0.22 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor; import static java.util.Arrays.asList; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor; import static java.util.Arrays.asList; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.NANOSECONDS;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
failures.add(failure); } }); final ListeningExecutorService executor = MoreExecutors.listeningDecorator(newSingleThreadExecutor()); final ExecutorService closingExecutor = newSingleThreadExecutor(); final TestCloseable closeable1 = new TestCloseable("closeable1"); final TestCloseable closeable2 = new TestCloseable("closeable2");
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
failures.add(failure); } }); final ListeningExecutorService executor = MoreExecutors.listeningDecorator(newSingleThreadExecutor()); final ExecutorService closingExecutor = newSingleThreadExecutor(); final TestCloseable closeable1 = new TestCloseable("closeable1"); final TestCloseable closeable2 = new TestCloseable("closeable2");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/MoreFilesTest.java
Path dirToDelete = fs.getPath("dir/b/i"); Path changingFile = dirToDelete.resolve("j/l"); Path symlinkTarget = fs.getPath("/dontdelete"); ExecutorService executor = Executors.newSingleThreadExecutor(); startDirectorySymlinkSwitching(changingFile, symlinkTarget, executor); try { for (int i = 0; i < iterations; i++) { try {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jan 29 22:57:05 GMT 2024 - 27.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* despite not throwing a RejectedExecutionException synchronously with the call to {@code * execute}. If this behaviour is problematic, use an Executor with a single thread (e.g. {@link * Executors#newSingleThreadExecutor}). * * @since 23.3 (since 23.1 as {@code sequentialExecutor}) */ @J2ktIncompatible @GwtIncompatible public static Executor newSequentialExecutor(Executor delegate) {
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) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator; import static java.lang.Thread.State.WAITING; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator; import static java.lang.Thread.State.WAITING; import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.MINUTES; import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0)