| /foundation/bundlemanager/app_domain_verify/test/unittest/mock/include/mock_ffrt/ |
| H A D | ffrt.h | 20 class queue { class
22 queue(std::string name){}; in queue() function in ffrt::queue
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | task_queue.h | 40 auto AddFutureTaskOrRunDirectly(const ITaskQueue::Ptr& queue, Func func) in AddFutureTaskOrRunDirectly() argument
|
| H A D | event_handler.h | 147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); Subscribe() local
[all...] |
| H A D | future.h | 95 IFuture::Ptr Then(const IFutureContinuation::Ptr& func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
100 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
105 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue, int = 0) in Then() argument
120 queue)); in Then() variable
|
| H A D | deferred_callback.h | 104 auto MakeDeferred(Func func, const ITaskQueue::Ptr& queue) in MakeDeferred() argument
|
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
| H A D | wifi_direct_event_dispatcher.cpp | 21 WifiDirectEventDispatcher::WifiDirectEventDispatcher(WifiDirectEventQueue *queue) in WifiDirectEventDispatcher() argument
|
| H A D | wifi_direct_event_sender.h | 23 explicit WifiDirectEventSender(WifiDirectEventQueue *queue) : queue_(queue) {} in WifiDirectEventSender() argument
|
| /foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | queue.h | 111 class queue { class
113 queue(const queue_type type, const char* name, const queue_attr& attr = {}) in queue() function in ffrt::queue
118 queue(const char* name, const queue_attr& attr = {}) in queue() function in ffrt::queue
[all...] |
| /foundation/arkui/ace_engine_lite/frameworks/src/core/stylemgr/test/unittest/common/ |
| H A D | link_queue_test.cpp | 34 LinkQueue queue; in HWTEST_F() local
52 LinkQueue queue; in HWTEST_F() local
70 LinkQueue queue; HWTEST_F() local
88 LinkQueue queue; HWTEST_F() local
131 LinkQueue queue; HWTEST_F() local
[all...] |
| /foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/ |
| H A D | fms_form_serial_queue_test.cpp | 59 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
76 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
96 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine_worker.cpp | 28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker() argument
32 static void ClearQueue(Queue<Task> &queue) in ClearQueue() argument
|
| H A D | sync_msg_handler.cpp | 28 SyncMsgHandler::SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm) in SyncMsgHandler() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/ |
| H A D | property_event_handler.h | 44 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const ITaskQueue::Ptr& queue) in Subscribe() argument
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 32 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask() argument
|
| /foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | audio_sink_filter_unit_test.h | 45 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| H A D | subtitle_sink_filter_unit_test.cpp | 40 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta) in OnLinkedResult() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | lock_free_queue.c | 31 register LockFreeQueue *queue = (LockFreeQueue *)SAMGR_Malloc(sizeof(LockFreeQueue) + total);
in LFQUE_Create() local
42 BOOL LFQUE_IsFull(LockFreeQueue *queue)
in LFQUE_IsFull() argument
51 LFQUE_IsEmpty(LockFreeQueue *queue) LFQUE_IsEmpty() argument
56 LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) LFQUE_Push() argument
88 LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) LFQUE_Pop() argument
[all...] |
| H A D | queue_adapter.c | 26 LockFreeQueue *queue;
member
31 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)SAMGR_Malloc(sizeof(LockFreeBlockQueue));
in QUEUE_Create() local
51 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Put() local
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Pop() local
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Destroy() local
[all...] |
| /foundation/communication/dsoftbus/tests/core/common/queue/ |
| H A D | queue_test.cpp | 54 LockFreeQueue queue; in HWTEST_F() local
86 LockFreeQueue queue; in HWTEST_F() local
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); in HWTEST_F() local
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/ |
| H A D | uv_queue.cpp | 33 auto queue = entry->uvQueue_.lock(); in ExecUvWork() local
|
| /foundation/ai/ai_engine/test/common/queuepool/ |
| H A D | queuepool_test.cpp | 70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
156 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
179 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
274 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
294 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
314 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
340 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
360 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
382 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
411 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
429 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
458 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
490 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
[all...] |
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| H A D | event_queue.h | 223 std::list<InnerEvent::Pointer> queue; global() member
[all...] |
| /foundation/multimedia/av_codec/test/unittest/decoder_filter_test/ |
| H A D | audio_decoder_filter_unit_test.h | 75 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| H A D | video_resize_filter_unit_test.h | 73 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | loop_api.cpp | 25 ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue) in ffrt_loop_create() argument
|