- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for executor (0.24 sec)
-
impl/maven-core/lifecycle-executor.txt
<plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-resources-plugin</artifactId> <executions> <execution> <goals> <goal>process</goal> </goals> </execution> </executions> </plugin> . . . </plugins>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 9.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
/** The future that represents the next execution of this task. */ @GuardedBy("lock") @CheckForNull private SupplantableFuture cancellationDelegate; ReschedulableCallable( AbstractService service, ScheduledExecutorService executor, Runnable runnable) { this.wrappedRunnable = runnable; this.executor = executor; this.service = service; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 16:22:21 UTC 2024 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
executor.execute(task); return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
android/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);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 16:07:00 UTC 2024 - 26.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
executor.execute(task); return task; } /** * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that * will complete after execution. * * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 28.2 */ public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
ListenableFuture<I> input, AsyncFunction<? super I, ? extends O> function, Executor executor) { checkNotNull(executor); AsyncTransformFuture<I, O> output = new AsyncTransformFuture<>(input, function); input.addListener(output, rejectionPropagatingExecutor(executor, output)); return output; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 11K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
ListenableFuture<? extends V> input, Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback); input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> createAsync(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 9.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
@Inject private LegacySupport legacySupport; private final Executor executor; public DefaultArtifactResolver() { int threads = Integer.getInteger("maven.artifact.threads", 5); if (threads <= 1) { executor = Runnable::run; } else { executor = new ThreadPoolExecutor(
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 24.8K bytes - Viewed (0) -
impl/maven-core/pom.xml
</models> </configuration> </execution> </executions> </plugin> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>buildnumber-maven-plugin</artifactId> <executions> <execution> <id>create-buildnumber</id> <goals> <goal>create</goal>
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 13:40:16 UTC 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
*/ requireNonNull(futures); // Corner case: List is empty. if (futures.isEmpty()) { handleAllCompleted(); return; } // NOTE: If we ever want to use a custom executor here, have a look at CombinedFuture as we'll // need to handle RejectedExecutionException if (allMustSucceed) { // We need fail fast, so we have to keep track of which future failed so we can propagate
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0)