Home
last modified time | relevance | path

Searched refs:TaskFunction (Results 1 – 25 of 32) sorted by relevance

12

/aosp_15_r20/external/tensorflow/tensorflow/core/tfrt/run_handler_thread_pool/
H A Drun_handler_test.cc64 TaskFunction([&local_counter, &counter, &barrier, i]() { in TEST()
72 TaskFunction([&local_counter, &counter]() { in TEST()
169 TaskFunction(fn)); in TEST_P()
172 TaskFunction(fn2)); in TEST_P()
180 TaskFunction(fn)); in TEST_P()
183 TaskFunction(fn2)); in TEST_P()
221 /*is_blocking=*/true, TaskFunction([&result] { result = 2; })); in TEST_P()
224 /*is_blocking=*/true, TaskFunction([&result] { result = 2; })); in TEST_P()
227 /*is_blocking=*/true, TaskFunction([&result] { result = 3; })); in TEST_P()
230 /*is_blocking=*/true, TaskFunction([&result] { result = 3; })); in TEST_P()
[all …]
H A Drun_handler_concurrent_work_queue_test.cc82 ASSERT_FALSE(pool_->AddBlockingTask(TaskFunction([&n, &m] { in TEST_F()
96 pool_->AddBlockingTask(TaskFunction([&n, &m] { in TEST_F()
110 ASSERT_FALSE(pool_->AddBlockingTask(TaskFunction([&n, &m] { in TEST_F()
124 queue_->AddTask(TaskFunction([&n, &m] { in TEST_F()
137 pool_->AddTask(TaskFunction([&n, &m] { in TEST_F()
150 queue_->AddTask(TaskFunction([&n, &m] { in TEST_F()
154 ASSERT_FALSE(pool_->AddBlockingTask(TaskFunction([&n, &m] { in TEST_F()
H A Drun_handler.h148 void ScheduleInterOpClosure(TaskFunction fn);
149 void ScheduleIntraOpClosure(TaskFunction fn);
175 TaskFunction f;
194 Task CreateTask(TaskFunction f);
336 void AddWorkToQueue(ThreadWorkSource* tws, bool is_blocking, TaskFunction fn);
424 void AddTask(TaskFunction work) override;
426 Optional<TaskFunction> AddBlockingTask(TaskFunction work,
H A Drun_handler.cc65 RunHandlerEnvironment::Task RunHandlerEnvironment::CreateTask(TaskFunction f) { in CreateTask()
413 bool is_blocking, TaskFunction fn) { in AddWorkToQueue()
665 void ScheduleInterOpClosure(TaskFunction fn);
666 void ScheduleIntraOpClosure(TaskFunction fn);
995 void RunHandler::Impl::ScheduleInterOpClosure(TaskFunction fn) { in ScheduleInterOpClosure()
1001 void RunHandler::Impl::ScheduleIntraOpClosure(TaskFunction fn) { in ScheduleIntraOpClosure()
1041 void RunHandler::ScheduleInterOpClosure(TaskFunction fn) { in ScheduleInterOpClosure()
1045 void RunHandler::ScheduleIntraOpClosure(TaskFunction fn) { in ScheduleIntraOpClosure()
1066 void RunHandlerWorkQueue::AddTask(TaskFunction work) { in AddTask()
1071 Optional<TaskFunction> RunHandlerWorkQueue::AddBlockingTask( in AddBlockingTask()
[all …]
H A Drun_handler_concurrent_work_queue.h99 void AddTask(TaskFunction work) override;
101 Optional<TaskFunction> AddBlockingTask(TaskFunction work,
H A Drun_handler_concurrent_work_queue.cc79 void RunHandlerThreadWorkQueue::AddTask(TaskFunction work) { in AddTask()
83 Optional<TaskFunction> RunHandlerThreadWorkQueue::AddBlockingTask( in AddBlockingTask()
84 TaskFunction work, bool allow_queuing) { in AddBlockingTask()
/aosp_15_r20/hardware/google/aemu/base/include/aemu/base/async/
DRecurrentTask.h42 using TaskFunction = std::function<bool()>;
52 RecurrentTask(Looper* looper, TaskFunction function, Looper::Duration taskIntervalMs) in RecurrentTask()
66 RecurrentTask(Looper* looper, TaskFunction function, std::chrono::milliseconds interval) in RecurrentTask()
162 const TaskFunction mFunction;
207 static void schedule(Looper* looper, RecurrentTask::TaskFunction function,
214 SimpleRecurrentTask(Looper* looper, RecurrentTask::TaskFunction function, in SimpleRecurrentTask()
234 const RecurrentTask::TaskFunction mFunction;
/aosp_15_r20/hardware/google/aemu/base/include/aemu/base/threads/
DParallelTask.h91 using TaskFunction = std::function<void(ResultType*)>;
106 TaskFunction taskFunction,
129 TaskFunction mTaskFunction;
140 using TaskFunction = typename ParallelTask<ResultType>::TaskFunction;
145 TaskFunction taskFunction, in SelfDeletingParallelTask()
/aosp_15_r20/external/pigweed/pw_async_fuchsia/public/pw_async_fuchsia/
H A Ddispatcher.h26 pw::async::TaskFunction func;
32 pw::async::TaskFunction&& task, in PostAt()
44 pw::async::TaskFunction&& task, in PostAfter()
50 pw::async::TaskFunction&& task) { in Post()
H A Dtask.h44 explicit NativeTask(::pw::async::Task& task, TaskFunction&& f);
48 void set_function(TaskFunction&& f);
58 TaskFunction func_;
/aosp_15_r20/external/tensorflow/tensorflow/core/tfrt/runtime/
H A Dtf_threadpool_concurrent_work_queue.cc48 void TfThreadPoolWorkQueue::AddTask(tfrt::TaskFunction work) { in AddTask()
49 auto* copy = new tfrt::TaskFunction( in AddTask()
57 llvm::Optional<tfrt::TaskFunction> TfThreadPoolWorkQueue::AddBlockingTask( in AddBlockingTask()
58 tfrt::TaskFunction work, bool allow_queuing) { in AddBlockingTask()
H A Dtf_threadpool_concurrent_work_queue_test.cc72 tf_threadpool_cwq_->AddBlockingTask(tfrt::TaskFunction([&n, &m, &latch] { in TEST_F()
90 tf_threadpool_cwq_->AddTask(tfrt::TaskFunction([&n, &m, &latch] { in TEST_F()
107 tf_threadpool_cwq_->AddTask(tfrt::TaskFunction([&n, &m, &latch] { in TEST_F()
114 tf_threadpool_cwq_->AddBlockingTask(tfrt::TaskFunction([&n, &m, &latch] { in TEST_F()
H A Dtf_threadpool_concurrent_work_queue.h60 void AddTask(tfrt::TaskFunction work) override;
62 llvm::Optional<tfrt::TaskFunction> AddBlockingTask(
63 tfrt::TaskFunction work, bool allow_queuing) override;
H A Dwork_queue_interface.cc36 void AddTask(tfrt::TaskFunction work) override { in AddTask()
40 llvm::Optional<tfrt::TaskFunction> AddBlockingTask( in AddBlockingTask()
41 tfrt::TaskFunction work, bool allow_queuing) override { in AddBlockingTask()
H A Dwork_queue_interface.h78 tfrt::TaskFunction WrapWork(int64_t id, absl::string_view name, in WrapWork()
81 return tfrt::TaskFunction([id, name = std::string(name), in WrapWork()
/aosp_15_r20/external/pigweed/pw_async/public/pw_async/
H A Dfunction_dispatcher.h37 virtual Status Post(TaskFunction&& task_func) { in Post()
42 virtual Status PostAfter(TaskFunction&& task_func, in PostAfter()
48 virtual Status PostAt(TaskFunction&& task_func,
H A Dtask.h38 explicit Task(TaskFunction&& f) : native_type_(*this, std::move(f)) {} in Task()
47 void set_function(TaskFunction&& f) { in set_function()
/aosp_15_r20/external/pigweed/pw_async/
H A Dheap_dispatcher.cc29 static Result<TaskAndFunction*> New(TaskFunction&& task) { in New()
52 TaskFunction func;
56 Status HeapDispatcher::PostAt(TaskFunction&& task_func, in PostAt()
H A Ddocs.rst41 .. doxygentypedef:: pw::async::TaskFunction
55 a function or lambda (see ``pw::async::TaskFunction``) and submitted to run
60 ``Task`` s, as well as to keep per- ``Task`` data alongside the ``TaskFunction``
/aosp_15_r20/external/pigweed/pw_async_basic/public/pw_async_basic/
H A Dtask.h38 explicit NativeTask(::pw::async::Task& task, TaskFunction&& f) in NativeTask()
41 void set_function(TaskFunction&& f) { func_ = std::move(f); } in set_function()
48 TaskFunction func_ = nullptr;
/aosp_15_r20/external/pigweed/pw_bluetooth_sapphire/public/pw_bluetooth_sapphire/internal/host/common/
H A Dsmart_task.h29 pw::async::TaskFunction&& func = nullptr)
58 void set_function(pw::async::TaskFunction&& func) { func_ = std::move(func); } in set_function()
72 pw::async::TaskFunction func_ = nullptr;
/aosp_15_r20/system/chre/platform/linux/include/chre/platform/linux/task_util/
H A Dtask.h39 using TaskFunction = std::function<void()>;
60 Task(const TaskFunction &func, std::chrono::nanoseconds intervalOrDelay,
168 std::optional<TaskFunction> mFunc;
/aosp_15_r20/external/pigweed/pw_async_fuchsia/
H A Dtask.cc25 NativeTask::NativeTask(::pw::async::Task& task, TaskFunction&& f) in NativeTask()
32 void NativeTask::set_function(TaskFunction&& f) { func_ = std::move(f); } in set_function()
/aosp_15_r20/system/chre/platform/linux/task_util/
H A Dtask.cc22 Task::Task(const TaskFunction &func, std::chrono::nanoseconds intervalOrDelay, in Task()
62 TaskFunction func; in execute()
/aosp_15_r20/external/clang/lib/CodeGen/
H A DCGOpenMPRuntime.h492 llvm::Value *TaskFunction, QualType SharedsTy,
810 llvm::Value *TaskFunction, QualType SharedsTy,
845 llvm::Value *TaskFunction, QualType SharedsTy, Address Shareds,

12