Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for tasks (0.14 sec)

  1. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * turn, and does not create any threads of its own.
       *
       * <p>After execution begins on a thread from the {@code delegate} {@link Executor}, tasks are
       * polled and executed from a task queue until there are no more tasks. The thread will not be
       * released until there are no more tasks to run.
       *
       * <p>If a task is submitted while a thread is executing tasks from the task queue, the thread
    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)
  2. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          lastMethodCalled = "invokeAllTimeout";
          lastTimeoutInMillis = unit.toMillis(timeout);
          return inline.invokeAll(tasks, timeout, unit);
        }
    
        // Define the invokeAny methods to invoke the first task
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          assertTaskWrapped(tasks);
          lastMethodCalled = "invokeAny";
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     * Executor, and sequentially such that no two will ever be running at the same time.
     *
     * <p>Tasks submitted to {@link #execute(Runnable)} are executed in FIFO order.
     *
     * <p>The execution of tasks is done by one thread as long as there are tasks left in the queue.
     * When a task is {@linkplain Thread#interrupt interrupted}, execution of subsequent tasks
     * continues. See {@link QueueWorker#workOnQueue} for details.
     *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  4. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/JapicmpTask.java

    import org.gradle.api.provider.Property;
    import org.gradle.api.provider.Provider;
    import org.gradle.api.tasks.CacheableTask;
    import org.gradle.api.tasks.CompileClasspath;
    import org.gradle.api.tasks.Input;
    import org.gradle.api.tasks.Nested;
    import org.gradle.api.tasks.Optional;
    import org.gradle.api.tasks.OutputFile;
    import org.gradle.api.tasks.TaskAction;
    import org.gradle.util.GradleVersion;
    import org.gradle.workers.WorkQueue;
    Java
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 26 10:58:32 GMT 2023
    - 13.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

      private static class FakeExecutor implements Executor {
        Queue<Runnable> tasks = Queues.newArrayDeque();
    
        @Override
        public void execute(Runnable command) {
          tasks.add(command);
        }
    
        boolean hasNext() {
          return !tasks.isEmpty();
        }
    
        void runNext() {
          assertTrue("expected at least one task to run", hasNext());
          tasks.remove().run();
        }
    
        void runAll() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

          lastMethodCalled = "invokeAllTimeout";
          lastTimeoutInMillis = unit.toMillis(timeout);
          return inline.invokeAll(tasks, timeout, unit);
        }
    
        // Define the invokeAny methods to invoke the first task
        @Override
        public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
            throws ExecutionException, InterruptedException {
          assertTaskWrapped(tasks);
          lastMethodCalled = "invokeAny";
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jan 05 19:41:03 GMT 2023
    - 9.8K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java

                task.getDocumentationRoot().convention(extension.getUserManual().getStagedDocumentation());
                task.getJavadocRoot().convention(layout.getBuildDirectory().dir("javadoc"));
                task.dependsOn(tasks.named("javadocAll"));
            });
    
            tasks.named(LifecycleBasePlugin.CHECK_TASK_NAME, task -> task.dependsOn(checkDeadInternalLinks));
        }
    Java
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Fri Mar 01 05:46:51 GMT 2024
    - 17.7K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

      private static class FakeExecutor implements Executor {
        Queue<Runnable> tasks = Queues.newArrayDeque();
    
        @Override
        public void execute(Runnable command) {
          tasks.add(command);
        }
    
        boolean hasNext() {
          return !tasks.isEmpty();
        }
    
        void runNext() {
          assertTrue("expected at least one task to run", hasNext());
          tasks.remove().run();
        }
    
        void runAll() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     * cancelled).
     *
     * <p>This class serializes execution of <i>submitted</i> tasks but not any <i>listeners</i> of
     * those tasks.
     *
     * <p>Submitted tasks have a happens-before order as defined in the Java Language Specification.
     * Tasks execute with the same happens-before order that the function calls to {@link #submit} and
     * {@link #submitAsync} that submitted those tasks had.
     *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  10. maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecycleExecutionPlanCalculator.java

            final List<MojoExecution> mojoExecutions = new ArrayList<>();
    
            for (Task task : tasks) {
                if (task instanceof GoalTask) {
                    String pluginGoal = task.getValue();
    
                    String executionId = "default-cli";
                    int executionIdx = pluginGoal.indexOf('@');
                    if (executionIdx > 0) {
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Jan 10 12:55:54 GMT 2024
    - 26.3K bytes
    - Viewed (0)
Back to top