1 /*
2 * 程序清单：动态信号量
3 *
4 * 这个例子中将创建一个动态信号量（初始值为0 ）及一个动态线程，在这个动态线程中
5 * 将试图采用超时方式去持有信号量，应该超时返回。然后这个线程释放一次信号量，并
6 * 在后面继续采用永久等待方式去持有信号量， 成功获得信号量后返回。
7 */
8 #include <rtthread.h>
9 #include "tc_comm.h"
10
11 /* 指向线程控制块的指针 */
12 static rt_thread_t tid = RT_NULL;
13 /* 指向信号量的指针 */
14 static rt_sem_t sem = RT_NULL;
15 /* 线程入口 */
thread_entry(void * parameter)16 static void thread_entry(void* parameter)
17 {
18 rt_err_t result;
19 rt_tick_t tick;
20
21 /* 获得当前的OS Tick */
22 tick = rt_tick_get();
23
24 /* 试图持有一个信号量，如果10个OS Tick依然没拿到，则超时返回 */
25 result = rt_sem_take(sem, 10);
26 if (result == -RT_ETIMEOUT)
27 {
28 rt_tick_t new_tick = rt_tick_get();
29 /* 可以有两个 tick 的误差 */
30 if (new_tick - tick >= 12)
31 {
32 rt_kprintf("tick error to large: expect: 10, get %d\n",
33 new_tick - tick);
34
35 /* 如果失败，则测试失败 */
36 tc_done(TC_STAT_FAILED);
37 rt_sem_delete(sem);
38 return;
39 }
40 rt_kprintf("take semaphore timeout\n");
41 }
42 else
43 {
44 /* 因为并没释放信号量，应该是超时返回，否则测试失败 */
45 tc_done(TC_STAT_FAILED);
46 rt_sem_delete(sem);
47 return;
48 }
49
50 /* 释放一次信号量 */
51 rt_sem_release(sem);
52
53 /* 继续持有信号量，并永远等待直到持有到信号量 */
54 result = rt_sem_take(sem, RT_WAITING_FOREVER);
55 if (result != RT_EOK)
56 {
57 /* 返回不正确，测试失败 */
58 tc_done(TC_STAT_FAILED);
59 rt_sem_delete(sem);
60 return;
61 }
62
63 /* 测试成功 */
64 tc_done(TC_STAT_PASSED);
65 /* 删除信号量 */
66 rt_sem_delete(sem);
67 }
68
semaphore_dynamic_init()69 int semaphore_dynamic_init()
70 {
71 /* 创建一个信号量，初始值是0 */
72 sem = rt_sem_create("sem", 0, RT_IPC_FLAG_FIFO);
73 if (sem == RT_NULL)
74 {
75 tc_stat(TC_STAT_END | TC_STAT_FAILED);
76 return 0;
77 }
78
79 /* 创建线程 */
80 tid = rt_thread_create("thread",
81 thread_entry, RT_NULL, /* 线程入口是thread_entry, 入口参数是RT_NULL */
82 THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
83 if (tid != RT_NULL)
84 rt_thread_startup(tid);
85 else
86 tc_stat(TC_STAT_END | TC_STAT_FAILED);
87
88 return 0;
89 }
90
91 #ifdef RT_USING_TC
_tc_cleanup()92 static void _tc_cleanup()
93 {
94 /* 调度器上锁，上锁后，将不再切换到其他线程，仅响应中断 */
95 rt_enter_critical();
96
97 if (sem)
98 {
99 rt_sem_delete(sem);
100 sem = RT_NULL;
101 }
102
103 /* 删除线程 */
104 if (tid != RT_NULL && tid->stat != RT_THREAD_CLOSE)
105 {
106 rt_thread_delete(tid);
107 }
108
109 /* 调度器解锁 */
110 rt_exit_critical();
111
112 /* 设置TestCase状态 */
113 tc_done(TC_STAT_PASSED);
114 }
115
_tc_semaphore_dynamic()116 int _tc_semaphore_dynamic()
117 {
118 /* 设置TestCase清理回调函数 */
119 tc_cleanup(_tc_cleanup);
120 semaphore_dynamic_init();
121
122 /* 返回TestCase运行的最长时间 */
123 return 100;
124 }
125 /* 输出函数命令到finsh shell中 */
126 FINSH_FUNCTION_EXPORT(_tc_semaphore_dynamic, a dynamic semaphore example);
127 #else
128 /* 用户应用入口 */
rt_application_init()129 int rt_application_init()
130 {
131 semaphore_dynamic_init();
132
133 return 0;
134 }
135 #endif
136