Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 80 for executor (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top