Searched refs:tasks_ (Results 1 – 5 of 5) sorted by relevance
| /third_party/flutter/engine/flutter/fml/ |
| D | concurrent_message_loop.cc | 63 tasks_.push(task); in PostTask()
77 [&]() { return tasks_.size() > 0 || shutdown_; }); in WorkerMain()
79 if (tasks_.size() == 0) { in WorkerMain()
85 auto task = tasks_.front(); in WorkerMain()
86 tasks_.pop(); in WorkerMain()
|
| D | concurrent_message_loop.h | 41 std::queue<fml::closure> tasks_; variable
|
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/io/ |
| D | shard_reader.cc | 1096 …tasks_ = ShardTaskList::Combine(categoryTasks, category_op->GetReplacement(), num_elements, num_sa… in CreateTasksByCategory()
1098 tasks_.InitSampleIds(); in CreateTasksByCategory()
1099 RETURN_IF_NOT_OK((*category_op)(tasks_)); in CreateTasksByCategory()
1120 tasks_.ResizeTask(sample_count); in CreateTasksByRow()
1130 … tasks_.InsertTask(offset, TaskType::kCommonTask, offsets[shard_id][i][0], offsets[shard_id][i][1], in CreateTasksByRow()
1155 tasks_.ResizeTask(sample_count); in CreateLazyTasksByRow()
1170 tasks_.InsertTask(i, TaskType::kCommonTask, shard_id, i - current_offset, {}, json()); in CreateLazyTasksByRow()
1202 tasks_.InsertTask(TaskType::kPaddedTask, 0, 0, {}, json()); in CreateTasks()
1208 …MS_LOG(DEBUG) << "Succeed to create " << tasks_.Size() << " initial task to start with before samp… in CreateTasks()
1209 tasks_.InitSampleIds(); in CreateTasks()
[all …]
|
| /third_party/node/src/ |
| D | node_platform.cc | 68 tasks_.Push(std::make_unique<ScheduleTask>(this, std::move(task), in PostDelayedTask()
74 tasks_.Push(std::make_unique<StopTask>(this)); in Stop()
95 while (std::unique_ptr<Task> task = scheduler->tasks_.Pop()) in FlushTasks()
160 TaskQueue<Task> tasks_; member in node::WorkerThreadsTaskRunner::DelayedTaskScheduler
|
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/include/ |
| D | shard_reader.h | 312 ShardTaskList tasks_; // shard task list variable
|