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