Searched refs:taskQueue (Results 1 – 12 of 12) sorted by relevance
81 run.taskQueue.enqueue(prepareTargetTask); in buildAndRun()84 run.taskQueue.enqueueAll(installVogarTasks); in buildAndRun()106 task.after(run.taskQueue.getTasks()); in buildAndRun()108 run.taskQueue.enqueueAll(shutdownTasks); in buildAndRun()111 run.taskQueue.printTasks(); in buildAndRun()112 run.taskQueue.runTasks(); in buildAndRun()113 if (run.taskQueue.hasFailedTasks()) { in buildAndRun()114 run.taskQueue.printProblemTasks(); in buildAndRun()157 run.taskQueue.enqueue(build); in enqueueActionTasks()161 run.taskQueue.enqueue(prepareUserDir); in enqueueActionTasks()[all …]
103 public final TaskQueue taskQueue; field in Run184 this.taskQueue = new TaskQueue(console, maxConcurrentActions); in Run()
41 private ArrayDeque<Runnable> taskQueue; field in SerializeReentrantCallsDirectExecutor53 if (taskQueue != null) { in execute()65 while ((task = taskQueue.poll()) != null) { in completeQueuedTasks()76 if (taskQueue == null) { in enqueue()77 taskQueue = new ArrayDeque<Runnable>(4); in enqueue()79 taskQueue.add(r); in enqueue()
33 private final Queue<Runnable> taskQueue = new ArrayDeque<>(); field in TestingExecutorService72 while (!taskQueue.isEmpty()) { in resume()73 delegate.execute(checkNotNull(taskQueue.poll())); in resume()80 taskQueue.add(command); in execute()
445 abstract ExecutorService createNonBlockingExecutor(BlockingQueue<Runnable> taskQueue); in createNonBlockingExecutor() argument447 abstract ExecutorService createBlockingExecutor(BlockingQueue<Runnable> taskQueue); in createBlockingExecutor() argument526 BlockingQueue<Runnable> taskQueue) {530 taskQueue);534 public ExecutorService createBlockingExecutor(BlockingQueue<Runnable> taskQueue) {538 taskQueue);550 BlockingQueue<Runnable> taskQueue) {556 taskQueue,
55 FutureActivityTaskExecutor taskQueue = ((BaseApplication) getApplication()).getTaskExecutor(); in onCreate() local56 mTask = taskQueue.getTask(id); in onCreate()
62 BlockingQueue<Runnable> taskQueue) { in setUp()68 BlockingQueue<Runnable> taskQueue) { in setUp()
152 FutureActivityTaskExecutor taskQueue = in setPreviewDisplay() local154 taskQueue.execute(task); in setPreviewDisplay()
146 std::list<std::function<void()>> taskQueue; variable
888 taskQueue.push_back(std::move(task)); in enqueueTask()894 bool didWork = !taskQueue.empty(); in run()895 while (!taskQueue.empty()) { in run()896 taskQueue.front()(); in run()897 taskQueue.pop_front(); in run()
435 Task taskQueue[TASK_COUNT]; member in sw::Renderer
791 Task &task = taskQueue[qHead]; in findAvailableTasks()847 Task &task = taskQueue[qHead]; in findAvailableTasks()873 task[threadIndex] = taskQueue[(qHead - qSize) & TASK_COUNT_BITS]; in scheduleTask()