Lines Matching defs:queue_handle
97 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
101 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), nullptr);
104 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), nullptr);
113 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
121 ffrt_queue_destroy(queue_handle);
136 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_max, nullptr, nullptr);
137 ffrt_queue_destroy(queue_handle);
140 queue_handle = ffrt_queue_create(ffrt_queue_serial, nullptr, nullptr);
141 EXPECT_EQ(queue_handle == nullptr, 0);
142 ffrt_queue_destroy(queue_handle);
147 queue_handle = ffrt_queue_create(ffrt_queue_serial, nullptr, &queue_attr);
148 EXPECT_EQ(queue_handle == nullptr, 0);
150 ffrt_queue_destroy(queue_handle);
193 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
194 task = ffrt_queue_submit_h(queue_handle, nullptr, nullptr);
198 task = ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), nullptr);
217 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
228 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), nullptr);
232 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
234 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
244 ffrt_queue_destroy(queue_handle);
258 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
267 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), nullptr);
270 ffrt_queue_destroy(queue_handle);
286 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
295 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
302 ffrt_queue_destroy(queue_handle);
344 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
356 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
362 ffrt_queue_destroy(queue_handle);
373 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
374 EXPECT_TRUE(queue_handle != nullptr);
378 ffrt_queue_destroy(queue_handle);
391 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
392 EXPECT_TRUE(queue_handle != nullptr);
396 ffrt_queue_destroy(queue_handle);
407 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
408 EXPECT_TRUE(queue_handle != nullptr);
412 ffrt_queue_destroy(queue_handle);
427 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
428 EXPECT_TRUE(queue_handle != nullptr);
431 ffrt_queue_destroy(queue_handle);
496 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr);
506 ffrt_task_handle_t handle = ffrt_queue_submit_h(queue_handle,
512 ffrt_queue_submit(queue_handle, create_function_wrapper(emptyFunc, ffrt_function_kind_queue), &task_attr);
518 bool hasEmptyTask = ffrt_queue_has_task(queue_handle, name.c_str());
523 bool hasEmptyTask = ffrt_queue_has_task(queue_handle, "empty_function_.*");
526 hasEmptyTask = ffrt_queue_has_task(queue_handle, "random_function");
533 ffrt_queue_destroy(queue_handle);
548 ffrt_queue_t queue_handle = ffrt_queue_create(
559 ffrt_task_handle_t handle = ffrt_queue_submit_h(queue_handle,
565 ffrt_queue_submit(queue_handle, create_function_wrapper(emptyFunc, ffrt_function_kind_queue), &task_attr);
569 bool hasEmptyTask = ffrt_queue_has_task(queue_handle, "empty_function_3");
572 ffrt_queue_cancel_by_name(queue_handle, "empty_function_3");
574 hasEmptyTask = ffrt_queue_has_task(queue_handle, "empty_function_3");
578 hasEmptyTask = ffrt_queue_has_task(queue_handle, "empty_function_.*");
581 bool isIdle = ffrt_queue_is_idle(queue_handle);
584 ffrt_queue_cancel_all(queue_handle);
586 hasEmptyTask = ffrt_queue_has_task(queue_handle, "empty_function_.*");
590 ffrt_queue_cancel_and_wait(queue_handle);
593 isIdle = ffrt_queue_is_idle(queue_handle);
597 ffrt_queue_destroy(queue_handle);
610 ffrt_queue_t queue_handle = ffrt_queue_create(
639 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
645 handle = ffrt_queue_submit_h(queue_handle,
660 ffrt_queue_destroy(queue_handle);
674 ffrt_queue_t queue_handle = ffrt_queue_create(
694 ffrt_queue_submit_head(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr);
696 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[0], ffrt_function_kind_queue), &task_attr);
697 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[1], ffrt_function_kind_queue), &task_attr);
700 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[2], ffrt_function_kind_queue), &task_attr);
701 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[3], ffrt_function_kind_queue), &task_attr);
704 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[4], ffrt_function_kind_queue), &task_attr);
707 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[5], ffrt_function_kind_queue), &task_attr);
710 ffrt_task_handle_t handle = ffrt_queue_submit_head_h(queue_handle,
712 ffrt_queue_submit_head(queue_handle, create_function_wrapper(assignFuncs[7], ffrt_function_kind_queue), &task_attr);
719 ffrt_queue_destroy(queue_handle);
726 ffrt_queue_t queue_handle = ffrt_queue_create(
728 EXPECT_TRUE(queue_handle != nullptr);
731 ffrt_queue_destroy(queue_handle);