diff options
| author | bernard.xiong <[email protected]> | 2010-03-21 03:02:15 +0000 |
|---|---|---|
| committer | bernard.xiong <[email protected]> | 2010-03-21 03:02:15 +0000 |
| commit | b54960259e547faa1e6956b41edcebaa24d9b279 (patch) | |
| tree | e68b4b768769444f6423849d464c05603a015c87 /examples/kernel/semaphore_dynamic.c | |
| parent | f459d4811ed8c681391b3fbc873fe8db4128cae6 (diff) | |
add Chinese comments for semaphore examples.
git-svn-id: https://rt-thread.googlecode.com/svn/trunk@521 bbd45198-f89e-11dd-88c7-29a3b14d5316
Diffstat (limited to 'examples/kernel/semaphore_dynamic.c')
| -rw-r--r-- | examples/kernel/semaphore_dynamic.c | 68 |
1 files changed, 55 insertions, 13 deletions
diff --git a/examples/kernel/semaphore_dynamic.c b/examples/kernel/semaphore_dynamic.c index be49459a4d..6bce4b91a2 100644 --- a/examples/kernel/semaphore_dynamic.c +++ b/examples/kernel/semaphore_dynamic.c @@ -1,55 +1,70 @@ +/*
+ * 程序清单:动态信号量
+ *
+ * 这个例子中将创建一个动态信号量(初始值为0 )及一个动态线程,在这个动态线程中
+ * 将试图采用超时方式去持有信号量,应该超时返回。然后这个线程释放一次信号量,并
+ * 在后面继续采用永久等待方式去持有信号量, 成功获得信号量后返回。
+ */
#include <rtthread.h>
#include "tc_comm.h"
-static rt_sem_t sem;
+/* 指向线程控制块的指针 */
+static rt_thread_t tid = RT_NULL;
+/* 指向信号量的指针 */
+static rt_sem_t sem = RT_NULL;
+/* 线程入口 */
static void thread_entry(void* parameter)
{
rt_err_t result;
rt_tick_t tick;
- /* get current tick */
+ /* 获得当前的OS Tick */
tick = rt_tick_get();
- /* take a semaphore for 10 OS Tick */
+ /* 视图持有一个信号量,如果10个OS Tick依然没拿到,则超时返回 */
result = rt_sem_take(sem, 10);
if (result == -RT_ETIMEOUT)
{
+ /* 判断是否刚好过去10个OS Tick */
if (rt_tick_get() - tick != 10)
{
+ /* 如果失败,则测试失败 */
tc_done(TC_STAT_FAILED);
rt_sem_delete(sem);
return;
}
- rt_kprintf("take semaphore timeout");
+ rt_kprintf("take semaphore timeout\n");
}
else
{
+ /* 因为并没释放信号量,应该是超时返回,否则测试失败 */
tc_done(TC_STAT_FAILED);
rt_sem_delete(sem);
return;
}
- /* release semaphore one time */
+ /* 释放一次信号量 */
rt_sem_release(sem);
+ /* 继续持有信号量,并永远等待直到持有到信号量 */
result = rt_sem_take(sem, RT_WAITING_FOREVER);
if (result != RT_EOK)
{
+ /* 返回不正确,测试失败 */
tc_done(TC_STAT_FAILED);
rt_sem_delete(sem);
return;
}
- /* testcase passed */
+ /* 测试成功 */
tc_done(TC_STAT_PASSED);
- /* delete semaphore */
+ /* 删除信号量 */
rt_sem_delete(sem);
}
int semaphore_dynamic_init()
{
- rt_thread_t tid;
-
+ /* 创建一个信号量,初始值是0 */
sem = rt_sem_create("sem", 0, RT_IPC_FLAG_FIFO);
if (sem == RT_NULL)
{
@@ -57,8 +72,9 @@ int semaphore_dynamic_init() return 0;
}
- tid = rt_thread_create("test",
- thread_entry, RT_NULL,
+ /* 创建线程 */
+ tid = rt_thread_create("thread",
+ thread_entry, RT_NULL, /* 线程入口是thread_entry, 入口参数是RT_NULL */
THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
if (tid != RT_NULL)
rt_thread_startup(tid);
@@ -69,14 +85,40 @@ int semaphore_dynamic_init() }
#ifdef RT_USING_TC
+static void _tc_cleanup()
+{
+ /* 调度器上锁,上锁后,将不再切换到其他线程,仅响应中断 */
+ rt_enter_critical();
+
+ /* 删除线程 */
+ if (tid != RT_NULL && tid->stat != RT_THREAD_CLOSE)
+ {
+ rt_thread_delete(tid);
+
+ /* 删除信号量 */
+ rt_sem_delete(sem);
+ }
+
+ /* 调度器解锁 */
+ rt_exit_critical();
+
+ /* 设置TestCase状态 */
+ tc_done(TC_STAT_PASSED);
+}
+
int _tc_semaphore_dynamic()
{
+ /* 设置TestCase清理回调函数 */
+ tc_cleanup(_tc_cleanup);
semaphore_dynamic_init();
- return 30;
+ /* 返回TestCase运行的最长时间 */
+ return 100;
}
-FINSH_FUNCTION_EXPORT(_tc_semaphore_dynamic, a dynamic semaphore test);
+/* 输出函数命令到finsh shell中 */
+FINSH_FUNCTION_EXPORT(_tc_semaphore_dynamic, a dynamic semaphore example);
#else
+/* 用户应用入口 */
int rt_application_init()
{
semaphore_dynamic_init();
|
