Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 153 for tasks (0.22 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. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
          throws InterruptedException {
        Preconditions.checkNotNull(tasks, "tasks must not be null!");
        return delegate.invokeAll(tasks);
      }
    
      @Override
      public <T> List<Future<T>> invokeAll(
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        Preconditions.checkNotNull(task, "task must not be null!");
        return delegate.submit(task);
      }
    
      @Override
      public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
          throws InterruptedException {
        Preconditions.checkNotNull(tasks, "tasks must not be null!");
        return delegate.invokeAll(tasks);
      }
    
      @Override
      public <T> List<Future<T>> invokeAll(
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  5. 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)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * implemented as "no-effort". No interrupts or other attempts are made to stop threads executing
       * tasks. Second, the returned list will always be empty, as any submitted task is considered to
       * have started execution. This applies also to tasks given to {@code invokeAll} or {@code
       * invokeAny} which are pending serial execution, even the subset of the tasks that have not yet
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleDslReferencePlugin.java

            TaskProvider<Docbook2Xhtml> dslHtml = tasks.register("dslHtml", Docbook2Xhtml.class, task -> {
                task.setGroup("documentation");
                task.setDescription("Generates DSL reference HTML documentation.");
                task.onlyIf(t -> !extension.getQuickFeedback().get());
    
                task.source(dslStandaloneDocbook);
                task.getStylesheetDirectory().convention(dslReference.getStylesheetDirectory());
    Java
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 5.7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java

       * Executor Ever.
       *
       * @author cbiffle
       */
      public static class FakeExecutor implements Executor {
        List<Runnable> tasks = Lists.newArrayList();
    
        @Override
        public void execute(Runnable task) {
          tasks.add(task);
        }
    
        public List<Runnable> getTasks() {
          return tasks;
        }
      }
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 2.3K bytes
    - Viewed (0)
Back to top