Searched refs:tasks (Results 1 – 6 of 6) sorted by relevance
73 final TestTask[] tasks = new TestTask[TASK_COUNT]; in concurrentProcessingTestIteration() local77 tasks[i] = new TestTask(Integer.valueOf(i + 1), result::addAndGet); in concurrentProcessingTestIteration()82 threads[i] = factory.createRunner(tasks); in concurrentProcessingTestIteration()107 protected final TestTask[] tasks; field in Main.TaskRunner109 TaskRunner(TestTask[] tasks) { in TaskRunner() argument110 this.tasks = tasks; in TaskRunner()117 TestTask t = (TestTask) QA.get(tasks, i); in run()149 TaskRunnerWithCompareAndExchange(TestTask[] tasks) { in TaskRunnerWithCompareAndExchange() argument150 super(tasks); in TaskRunnerWithCompareAndExchange()155 return (t == QA.compareAndExchange(tasks, i, t, null)); in grabTask()[all …]
61 private PriorityQueue<Pair<RunnableScheduledFuture<?>, Long>> tasks = new PriorityQueue<>( field in MockClock.ScheduledExecutor74 tasks.add(Pair.create(task, getCurrentTimeMs() + unit.toMillis(delay))); in schedule()79 while (!tasks.isEmpty()) { in notifyUpdate()80 Pair<RunnableScheduledFuture<?>, Long> pair = tasks.peek(); in notifyUpdate()87 tasks.poll(); in notifyUpdate()
77 ArrayList<Callable<Integer>> tasks = new ArrayList<>(CONCURRENCY); in runTasks() local79 tasks.add(i, task); in runTasks()82 List<Future<Integer>> results = executorService.invokeAll(tasks); in runTasks()
3 artd is a component of ART Service. It is a shim service to do tasks that
1631 std::deque<Task*> tasks; in BootCompleted() local1634 tasks = std::move(tasks_after_boot_); in BootCompleted()1637 for (Task* task : tasks) { in BootCompleted()
1612 std::vector<std::unique_ptr<RaceGenerateTask>> tasks; in TEST_F() local1618 tasks.push_back(std::move(task)); in TEST_F()1625 for (auto& task : tasks) { in TEST_F()