Lines Matching full:task
15 using v8::Task;
20 TaskQueue<Task>* task_queue;
31 TaskQueue<Task>* pending_worker_tasks = worker_data->task_queue; in PlatformWorkerThread()
42 while (std::unique_ptr<Task> task = pending_worker_tasks->BlockingPop()) { in PlatformWorkerThread() local
43 task->Run(); in PlatformWorkerThread()
59 explicit DelayedTaskScheduler(TaskQueue<Task>* tasks) in DelayedTaskScheduler()
74 void PostDelayedTask(std::unique_ptr<Task> task, double delay_in_seconds) { in PostDelayedTask() argument
75 tasks_.Push(std::make_unique<ScheduleTask>(this, std::move(task), in PostDelayedTask()
102 while (std::unique_ptr<Task> task = scheduler->tasks_.Pop()) in FlushTasks() local
103 task->Run(); in FlushTasks()
106 class StopTask : public Task {
124 class ScheduleTask : public Task {
127 std::unique_ptr<Task> task, in ScheduleTask() argument
130 task_(std::move(task)), in ScheduleTask()
144 std::unique_ptr<Task> task_;
154 std::unique_ptr<Task> TakeTimerTask(uv_timer_t* timer) { in TakeTimerTask()
155 std::unique_ptr<Task> task(static_cast<Task*>(timer->data)); in TakeTimerTask() local
161 return task; in TakeTimerTask()
165 TaskQueue<Task>* pending_worker_tasks_;
167 TaskQueue<Task> tasks_;
204 void WorkerThreadsTaskRunner::PostTask(std::unique_ptr<Task> task) { in PostTask() argument
205 pending_worker_tasks_.Push(std::move(task)); in PostTask()
208 void WorkerThreadsTaskRunner::PostDelayedTask(std::unique_ptr<Task> task, in PostDelayedTask() argument
210 delayed_task_scheduler_->PostDelayedTask(std::move(task), delay_in_seconds); in PostDelayedTask()
248 void PerIsolatePlatformData::PostIdleTask(std::unique_ptr<v8::IdleTask> task) { in PostIdleTask() argument
252 void PerIsolatePlatformData::PostTask(std::unique_ptr<Task> task) { in PostTask() argument
255 // sensible path forward is to discard the task. in PostTask()
258 foreground_tasks_.Push(std::move(task)); in PostTask()
263 std::unique_ptr<Task> task, double delay_in_seconds) { in PostDelayedTask() argument
266 // sensible path forward is to discard the task. in PostDelayedTask()
270 delayed->task = std::move(task); in PostDelayedTask()
277 void PerIsolatePlatformData::PostNonNestableTask(std::unique_ptr<Task> task) { in PostNonNestableTask() argument
278 PostTask(std::move(task)); in PostNonNestableTask()
282 std::unique_ptr<Task> task, in PostNonNestableDelayedTask() argument
284 PostDelayedTask(std::move(task), delay_in_seconds); in PostNonNestableDelayedTask()
417 void PerIsolatePlatformData::RunForegroundTask(std::unique_ptr<Task> task) { in RunForegroundTask() argument
425 task->Run(); in RunForegroundTask()
427 // The task is moved out of InternalCallbackScope if env is not available. in RunForegroundTask()
430 task->Run(); in RunForegroundTask()
434 void PerIsolatePlatformData::DeleteFromScheduledTasks(DelayedTask* task) { in DeleteFromScheduledTasks() argument
437 [task](const DelayedTaskPointer& delayed) -> bool { in DeleteFromScheduledTasks()
438 return delayed.get() == task; in DeleteFromScheduledTasks()
446 delayed->platform_data->RunForegroundTask(std::move(delayed->task)); in RunForegroundTask()
480 std::unique_ptr<DelayedTask> task { in FlushForegroundTasksInternal() local
482 task->platform_data->DecreaseHandleCount(); in FlushForegroundTasksInternal()
489 std::queue<std::unique_ptr<Task>> tasks = foreground_tasks_.PopAll(); in FlushForegroundTasksInternal()
491 std::unique_ptr<Task> task = std::move(tasks.front()); in FlushForegroundTasksInternal() local
494 RunForegroundTask(std::move(task)); in FlushForegroundTasksInternal()
499 void NodePlatform::CallOnWorkerThread(std::unique_ptr<Task> task) { in CallOnWorkerThread() argument
500 worker_thread_task_runner_->PostTask(std::move(task)); in CallOnWorkerThread()
503 void NodePlatform::CallDelayedOnWorkerThread(std::unique_ptr<Task> task, in CallDelayedOnWorkerThread() argument
505 worker_thread_task_runner_->PostDelayedTask(std::move(task), in CallDelayedOnWorkerThread()
578 void TaskQueue<T>::Push(std::unique_ptr<T> task) { in Push() argument
581 task_queue_.push(std::move(task)); in Push()