- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 184 for executor_ (0.56 sec)
-
guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java
import java.util.Set; import java.util.concurrent.Executor; import java.util.concurrent.atomic.AtomicInteger; /** * A benchmark comparing the {@link MoreExecutors#newDirectExecutorService()} to {@link * MoreExecutors#directExecutor}. */ @VmOptions({"-Xms12g", "-Xmx12g", "-d64"}) public class MoreExecutorsDirectExecutorBenchmark { enum Impl { EXECUTOR_SERVICE { @Override Executor executor() {
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
import java.util.Set; import java.util.concurrent.Executor; import java.util.concurrent.atomic.AtomicInteger; /** * A benchmark comparing the {@link MoreExecutors#newDirectExecutorService()} to {@link * MoreExecutors#directExecutor}. */ @VmOptions({"-Xms12g", "-Xmx12g", "-d64"}) public class MoreExecutorsDirectExecutorBenchmark { enum Impl { EXECUTOR_SERVICE { @Override Executor executor() {
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) -
src/main/java/org/codelibs/fess/util/ComponentUtil.java
return getComponent(EXTRACTOR_FACTORY); } public static JobExecutor getJobExecutor(final String name) { if (name.endsWith(JOB_EXECUTOR_SUFFIX)) { return getComponent(name); } return getComponent("script" + JOB_EXECUTOR_SUFFIX); } public static FileTypeHelper getFileTypeHelper() { return getComponent(FILE_TYPE_HELPER); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 20K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * @param executor The executor to decorate * @param nameSupplier The source of names for each task */ @J2ktIncompatible @GwtIncompatible // concurrency static Executor renamingDecorator(final Executor executor, final Supplier<String> nameSupplier) { checkNotNull(executor); checkNotNull(nameSupplier); return new Executor() { @Override
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-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isCancelled()); ExecutorService executor = Executors.newSingleThreadExecutor(); try { Future<Boolean> getResult = executor.submit(() -> future.get()); // Release the future value. latch.countDown(); assertTrue(getResult.get(10, SECONDS)); } finally { executor.shutdownNow(); } assertTrue(future.isDone());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
src/test/java/jcifs/tests/WatchTest.java
@Before public void setUp () throws Exception { super.setUp(); this.executor = Executors.newSingleThreadExecutor(); this.base = createTestDirectory(); } @Override @After public void tearDown () throws Exception { if ( this.executor != null ) { this.executor.shutdown(); if ( this.future != null ) { this.future.cancel(true);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testRunIdempotency() throws Exception { final int numThreads = 10; final ExecutorService executor = Executors.newFixedThreadPool(numThreads); for (int i = 0; i < 1000; i++) { final AtomicInteger counter = new AtomicInteger(); final TrustedListenableFutureTask<Integer> task =
Java - Registered: Fri May 03 12:43:13 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/ClosingFutureFinishToValueAndCloserTest.java
import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; /** * Tests for {@link ClosingFuture} that exercise {@link * ClosingFuture#finishToValueAndCloser(ValueAndCloserConsumer, Executor)}. */ public class ClosingFutureFinishToValueAndCloserTest extends AbstractClosingFutureTest {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
ScheduledExecutorService executor = newScheduledThreadPool(1); try { FluentFuture<?> f = FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor); ExecutionException e = assertThrows(ExecutionException.class, () -> f.get()); assertThat(e).hasCauseThat().isInstanceOf(TimeoutException.class); } finally { executor.shutdown(); } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/MoreFilesTest.java
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 { Files.createDirectories(changingFile);
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)