kupl_queue_submit

向queue提交需要执行的item。

接口定义

int kupl_queue_submit(kupl_queue_h queue, kupl_queue_item_desc_t *desc);

参数

表1 参数定义
参数名	类型	描述	输入/输出
queue	kupl_queue_h	执行 item 的 queue	输入
desc	kupl_queue_item_desc_t	queue_item 的描述	输入

表2 kupl_queue_item_desc_t 的数据结构
参数名	类型	描述
field_mask	uint64_t	结构体中有效字段的掩码，使用kupl_queue_item_desc_field中的位标识。此掩码中未指定的字段将被忽略。具体可设置的掩码： KUPL_QUEUE_ITEM_DESC_FIELD_NAME：name生效 KUPL_QUEUE_ITEM_DESC_FIELD_EGROUP：egroup生效
func	kupl_queue_item_func_t	queue_item 的函数指针
args	void *	queue_item 的参数
name	const char *	queue_item 的名字
egroup	kupl_egroup_h	指定当前queue_item的亲和性信息

kupl_queue_item_func_t的定义

void (*kupl_queue_item_func_t)(void *args);

返回值

成功：返回 KUPL_OK

失败：返回 KUPL_ERROR

示例

#include <stdio.h> 
#include <assert.h>
#include "kupl.h" 

static inline void kernel_func(void *args)
{
    printf("kernel exec.\n");
}

int main() 
{ 
    kupl_queue_h queue = kupl_queue_create();
    kupl_queue_item_desc_t desc = {
        .field_mask = KUPL_QUEUE_ITEM_DESC_FIELD_NAME,
        .func = kernel_func,
        .args = NULL,
        .name = "kernel_name"
    };
    int ret = kupl_queue_submit(queue, &desc); 
    assert(ret == KUPL_OK);
    kupl_queue_wait(queue);
    kupl_queue_destroy(queue);
    return 0;         
}

运行结果如下。

kernel exec.

上述示例演示了向 queue 提交 kernel，并等待直到 queue 上全部 kernel 执行完成的流程。上述kupl_queue_submit 函数向 queue 上提交需要执行的 kernel。

父主题： 多队列多流编程函数