1.completion 是什么

completion 直接翻譯過(guò)來(lái)是完成，所以我更愿意稱 rt_completion 為 完成量。在 RT-Thread 的文檔中心 中講線程間通訊（IPC）時(shí)，只介紹了，信號(hào)量， 互斥量， 事件集，其實(shí) rt_completion 可以認(rèn)為是輕量級(jí)的二值信號(hào)量。

2.completion 怎么使用

completion 的使用非常簡(jiǎn)單

定義一個(gè)完成量

struct rt_completion completion;

初始化完成量

rt_completion_init(&completion);

等待完成量

rt_completion_wait(&completion);

釋放完成量

rt_completion_done(&completion);

3.completion 的實(shí)現(xiàn)

completion 的 API 非常少，可以通過(guò)簡(jiǎn)單的代碼去分析

初始化完成量

void rt_completion_init(struct rt_completion *completion)

{

rt_base_t level;

RT_ASSERT(completion != RT_NULL);

level = rt_hw_interrupt_disable();

completion->flag = RT_UNCOMPLETED;

rt_list_init(&completion->suspended_list);

rt_hw_interrupt_enable(level);

}

干了兩件事：

設(shè)置 flag 為 RT_UNCOMPLETED

初始化完成量的鏈表

等待完成量(以下代碼有刪減)

rt_err_t rt_completion_wait(struct rt_completion *completion,

rt_int32_t timeout)

{

result = RT_EOK;

thread = rt_thread_self();

level = rt_hw_interrupt_disable();

if (completion->flag != RT_COMPLETED)

{

if (timeout == 0)

{

}

else

{

/* reset thread error number */

thread->error = RT_EOK;

/* suspend thread */

rt_thread_suspend(thread);

/* add to suspended list */

rt_list_insert_before(&(completion->suspended_list),

&(thread->tlist));

/* current context checking */

RT_DEBUG_NOT_IN_INTERRUPT;

/* start timer */

if (timeout > 0)

{

/* reset the timeout of thread timer and start it */

rt_timer_control(&(thread->thread_timer),

RT_TIMER_CTRL_SET_TIME,

&timeout);

rt_timer_start(&(thread->thread_timer));

}

/* enable interrupt */

rt_hw_interrupt_enable(level);

/* do schedule */

rt_schedule();

/* thread is waked up */

result = thread->error;

level = rt_hw_interrupt_disable();

}

}

/* clean completed flag */

completion->flag = RT_UNCOMPLETED;

return result;

}

主要做了以下工作：

關(guān)中斷：rt_hw_interrupt_disable();

掛起當(dāng)前線程：rt_thread_suspend(thread);

把掛起狀態(tài)插入到線程的鏈表中：rt_list_insert_before

確保當(dāng)前函數(shù)執(zhí)行不是在中斷中：RT_DEBUG_NOT_IN_INTERRUPT;

設(shè)置并啟動(dòng)定時(shí)器：rt_timer_start(&(thread->thread_timer));

開中斷：rt_hw_interrupt_enable(level);

開調(diào)度器：rt_schedule();

獲取當(dāng)前線程狀態(tài)：result = thread->error;

設(shè)置完成量的標(biāo)志位：completion->flag = RT_UNCOMPLETED;

返回線程狀態(tài)

這樣就完成了線程的掛起。

完成完成量(以下代碼有刪減)

void rt_completion_done(struct rt_completion *completion)

{

level = rt_hw_interrupt_disable();

completion->flag = RT_COMPLETED;

if (!rt_list_isempty(&(completion->suspended_list)))

{

/* there is one thread in suspended list */

struct rt_thread *thread;

/* get thread entry */

thread = rt_list_entry(completion->suspended_list.next,

struct rt_thread,

tlist);

/* resume it */

rt_thread_resume(thread);

rt_hw_interrupt_enable(level);

/* perform a schedule */

rt_schedule();

}

}

主要做了以下工作：

關(guān)中斷：rt_hw_interrupt_disable();

設(shè)置 flag 為 RT_COMPLETED

檢查鏈表不為空：rt_list_isempty

獲取到當(dāng)前等待完成量的句柄：rt_list_entry

啟動(dòng)被掛起的線程：rt_thread_resume(thread);

開中斷：rt_hw_interrupt_enable(level);

開調(diào)度：rt_schedule();

4.completion 與信號(hào)量的對(duì)比

completion API 個(gè)數(shù)少，資源占用少，只能釋放獲取，不支持多次釋放

semaphore API 個(gè)數(shù)多，資源占用較多，使用靈活，可以嘗試獲取，可以多次釋放，

5.completion 如何加入工程

標(biāo)準(zhǔn)版 RT-Thread 中的 completion 源碼在 "\\rt-thread\\components\\drivers\\src\\completion.c"在你要使用的文件中#include completion.h直接就可以使用。

Nano 版 RT-Thread 直接拷貝completion.c 和 completion.h 添加到工程就可以使用。