Home
last modified time | relevance | path

Searched refs:taskQueue (Results 1 – 15 of 15) sorted by relevance

/external/cronet/tot/base/test/android/javatests/src/org/chromium/base/test/task/
DSchedulerTestHelpers.java19 TaskRunner taskQueue, List<Integer> orderList, int order) { in postRecordOrderTask() argument
20 postRecordOrderDelayedTask(taskQueue, orderList, order, 0); in postRecordOrderTask()
24 TaskRunner taskQueue, List<Integer> orderList, int order, long delay) { in postRecordOrderDelayedTask() argument
25 taskQueue.postDelayedTask(() -> orderList.add(order), delay); in postRecordOrderDelayedTask()
28 public static void postTaskAndBlockUntilRun(TaskRunner taskQueue) { in postTaskAndBlockUntilRun() argument
29 postDelayedTaskAndBlockUntilRun(taskQueue, 0); in postTaskAndBlockUntilRun()
32 public static void postDelayedTaskAndBlockUntilRun(TaskRunner taskQueue, long delay) { in postDelayedTaskAndBlockUntilRun() argument
35 taskQueue.postDelayedTask( in postDelayedTaskAndBlockUntilRun()
54 public static void postThreeTasksInOrder(TaskRunner taskQueue, List<Integer> orderList) { in postThreeTasksInOrder() argument
55 postRecordOrderTask(taskQueue, orderList, 1); in postThreeTasksInOrder()
[all …]
/external/cronet/stable/base/test/android/javatests/src/org/chromium/base/test/task/
DSchedulerTestHelpers.java19 TaskRunner taskQueue, List<Integer> orderList, int order) { in postRecordOrderTask() argument
20 postRecordOrderDelayedTask(taskQueue, orderList, order, 0); in postRecordOrderTask()
24 TaskRunner taskQueue, List<Integer> orderList, int order, long delay) { in postRecordOrderDelayedTask() argument
25 taskQueue.postDelayedTask(() -> orderList.add(order), delay); in postRecordOrderDelayedTask()
28 public static void postTaskAndBlockUntilRun(TaskRunner taskQueue) { in postTaskAndBlockUntilRun() argument
29 postDelayedTaskAndBlockUntilRun(taskQueue, 0); in postTaskAndBlockUntilRun()
32 public static void postDelayedTaskAndBlockUntilRun(TaskRunner taskQueue, long delay) { in postDelayedTaskAndBlockUntilRun() argument
35 taskQueue.postDelayedTask( in postDelayedTaskAndBlockUntilRun()
54 public static void postThreeTasksInOrder(TaskRunner taskQueue, List<Integer> orderList) { in postThreeTasksInOrder() argument
55 postRecordOrderTask(taskQueue, orderList, 1); in postThreeTasksInOrder()
[all …]
/external/vogar/src/vogar/
DDriver.java81 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 …]
DRun.java105 public final TaskQueue taskQueue; field in Run
191 this.taskQueue = new TaskQueue(console, maxConcurrentActions); in Run()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DSerializeReentrantCallsDirectExecutor.java41 private ArrayDeque<Runnable> taskQueue; field in SerializeReentrantCallsDirectExecutor
53 if (taskQueue != null) { in execute()
65 while ((task = taskQueue.poll()) != null) { in completeQueuedTasks()
76 if (taskQueue == null) { in enqueue()
77 taskQueue = new ArrayDeque<>(4); in enqueue()
79 taskQueue.add(r); in enqueue()
/external/cronet/stable/base/android/javatests/src/org/chromium/base/task/
DSequencedTaskRunnerImplTest.java34 TaskRunner taskQueue = new SequencedTaskRunnerImpl(TaskTraits.USER_BLOCKING); in testPreNativeTasksRunInOrder() local
36 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 1); in testPreNativeTasksRunInOrder()
37 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 2); in testPreNativeTasksRunInOrder()
38 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 3); in testPreNativeTasksRunInOrder()
39 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testPreNativeTasksRunInOrder()
DPostTaskTest.java49 TaskRunner taskQueue = PostTask.createSequencedTaskRunner(TaskTraits.USER_BLOCKING); in testCreateSequencedTaskRunner() local
51 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 1); in testCreateSequencedTaskRunner()
52 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 2); in testCreateSequencedTaskRunner()
53 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 3); in testCreateSequencedTaskRunner()
54 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testCreateSequencedTaskRunner()
62 TaskRunner taskQueue = PostTask.createTaskRunner(TaskTraits.USER_BLOCKING); in testCreateTaskRunner() local
65 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testCreateTaskRunner()
/external/cronet/tot/base/android/javatests/src/org/chromium/base/task/
DSequencedTaskRunnerImplTest.java34 TaskRunner taskQueue = new SequencedTaskRunnerImpl(TaskTraits.USER_BLOCKING); in testPreNativeTasksRunInOrder() local
36 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 1); in testPreNativeTasksRunInOrder()
37 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 2); in testPreNativeTasksRunInOrder()
38 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 3); in testPreNativeTasksRunInOrder()
39 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testPreNativeTasksRunInOrder()
DPostTaskTest.java49 TaskRunner taskQueue = PostTask.createSequencedTaskRunner(TaskTraits.USER_BLOCKING); in testCreateSequencedTaskRunner() local
51 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 1); in testCreateSequencedTaskRunner()
52 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 2); in testCreateSequencedTaskRunner()
53 SchedulerTestHelpers.postRecordOrderTask(taskQueue, orderList, 3); in testCreateSequencedTaskRunner()
54 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testCreateSequencedTaskRunner()
62 TaskRunner taskQueue = PostTask.createTaskRunner(TaskTraits.USER_BLOCKING); in testCreateTaskRunner() local
65 SchedulerTestHelpers.postTaskAndBlockUntilRun(taskQueue); in testCreateTaskRunner()
/external/perfetto/ui/src/base/
Dasync_limiter.ts34 private readonly taskQueue: Task[] = []; property in AsyncLimiter
47 this.taskQueue.push({work, deferred});
60 while ((task = this.taskQueue.shift())) {
61 if (this.taskQueue.length > 0) {
/external/downloader/src/test/java/com/google/android/downloader/
DTestingExecutorService.java33 private final Queue<Runnable> taskQueue = new ArrayDeque<>(); field in TestingExecutorService
72 while (!taskQueue.isEmpty()) { in resume()
73 delegate.execute(checkNotNull(taskQueue.poll())); in resume()
80 taskQueue.add(command); in execute()
/external/volley/core/src/main/java/com/android/volley/
DAsyncRequestQueue.java503 BlockingQueue<Runnable> taskQueue); in createNonBlockingExecutor() argument
505 public abstract ExecutorService createBlockingExecutor(BlockingQueue<Runnable> taskQueue); in createBlockingExecutor() argument
584 BlockingQueue<Runnable> taskQueue) {
588 taskQueue);
592 public ExecutorService createBlockingExecutor(BlockingQueue<Runnable> taskQueue) {
596 taskQueue);
608 BlockingQueue<Runnable> taskQueue) {
614 taskQueue,
/external/sl4a/Common/src/com/googlecode/android_scripting/activity/
DFutureActivity.java55 FutureActivityTaskExecutor taskQueue = ((BaseApplication) getApplication()).getTaskExecutor(); in onCreate() local
56 mTask = taskQueue.getTask(id); in onCreate()
/external/sl4a/Common/src/com/googlecode/android_scripting/facade/
DCameraFacade.java152 FutureActivityTaskExecutor taskQueue = in setPreviewDisplay() local
154 taskQueue.execute(task); in setPreviewDisplay()
/external/volley/core/src/test/java/com/android/volley/
DAsyncRequestQueueTest.java183 BlockingQueue<Runnable> taskQueue) { in createRequestQueue()
189 BlockingQueue<Runnable> taskQueue) { in createRequestQueue() argument