Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 191 for Tasks (0.03 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

                }
            };
    
            // Generate multiple callable tasks
            final List<Callable<Integer>> tasks = new ArrayList<Callable<Integer>>();
            for (int i = 0; i < numTasks; i++) {
                tasks.add(testCallable);
            }
    
            // Get start time
            final long time = System.nanoTime();
    
            // Execute callable tasks concurrently
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
       * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        @Override
        public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
            throws InterruptedException {
          lastMethodCalled = "invokeAll";
          assertTaskWrapped(tasks);
          return inline.invokeAll(tasks);
        }
    
        @Override
        public <T> List<Future<T>> invokeAll(
            Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
            throws InterruptedException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  4. okhttp/build.gradle.kts

    import com.vanniktech.maven.publish.KotlinMultiplatform
    import org.jetbrains.kotlin.gradle.dsl.JvmTarget
    import org.jetbrains.kotlin.gradle.tasks.KotlinJvmCompile
    import ru.vyarus.gradle.plugin.animalsniffer.AnimalSniffer
    import ru.vyarus.gradle.plugin.animalsniffer.AnimalSnifferExtension
    import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
    
    plugins {
      kotlin("multiplatform")
      id("com.android.library")
      kotlin("plugin.serialization")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * tasks and to collections of tasks submitted via {@code invokeAll} or {@code invokeAny}. In the
       * latter case, tasks will run serially on the calling thread. Tasks are run to completion before
       * a {@code Future} is returned to the caller (unless the executor has been shutdown).
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleTaskSegmentCalculator.java

            MavenProject rootProject = session.getTopLevelProject();
    
            List<String> tasks = requireNonNull(session.getGoals()); // session never returns null, but empty list
    
            if (tasks.isEmpty()
                    && (rootProject.getDefaultGoal() != null
                            && !rootProject.getDefaultGoal().isEmpty())) {
                tasks = Stream.of(rootProject.getDefaultGoal().split("\\s+"))
                        .filter(g -> !g.isEmpty())
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Dec 13 23:07:01 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. okcurl/build.gradle.kts

    }
    
    configure<AnimalSnifferExtension> {
      isIgnoreFailures = true
    }
    
    tasks.jar {
      manifest {
        attributes("Automatic-Module-Name" to "okhttp3.curl")
        attributes("Main-Class" to "okhttp3.curl.MainCommandLineKt")
      }
    }
    
    tasks.shadowJar {
      mergeServiceFiles()
    }
    
    tasks.withType<Test> {
      onlyIf("native build requires Java 17") {
        testJavaVersion > 17
      }
    }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jul 22 20:31:49 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        BeforeOtherTasks,
    
        /** Resumes after the already-enqueued tasks. */
        AfterEnqueuedTasks,
    
        /** Resumes after all other tasks, including tasks enqueued while yielding. */
        AfterOtherTasks,
      }
    
      /** Returns the task that was started, or null if there were no tasks to start. */
      private fun startNextTask(): SerialTask? {
        taskRunner.assertLockHeld()
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  9. buildSrc/src/main/kotlin/JavaModules.kt

     * limitations under the License.
     */
    
    import me.champeau.mrjar.MultiReleaseExtension
    import org.gradle.api.Project
    import org.gradle.api.tasks.compile.JavaCompile
    import org.gradle.kotlin.dsl.configure
    import org.gradle.kotlin.dsl.named
    import org.jetbrains.kotlin.gradle.tasks.KotlinJvmCompile
    
    fun Project.applyJavaModules(
      moduleName: String,
      defaultVersion: Int = 8,
      javaModuleVersion: Int = 9,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Sep 21 06:22:22 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

          Collection<? extends Callable<T>> tasks) throws InterruptedException {
        return delegate().invokeAll(tasks);
      }
    
      @Override
      public <T extends @Nullable Object> List<Future<T>> invokeAll(
          Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
          throws InterruptedException {
        return delegate().invokeAll(tasks, timeout, unit);
      }
    
      @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top