1*10465441SEvalZero /*
2*10465441SEvalZero * 程序清单：唤醒线程
3*10465441SEvalZero *
4*10465441SEvalZero * 这个例子中将创建两个动态线程，低优先级线程将挂起自身，然后
5*10465441SEvalZero * 高优先级线程将在一定时刻后唤醒低优先级线程。
6*10465441SEvalZero */
7*10465441SEvalZero #include <rtthread.h>
8*10465441SEvalZero #include "tc_comm.h"
9*10465441SEvalZero
10*10465441SEvalZero /* 指向线程控制块的指针 */
11*10465441SEvalZero static rt_thread_t tid1 = RT_NULL;
12*10465441SEvalZero static rt_thread_t tid2 = RT_NULL;
13*10465441SEvalZero /* 线程1入口 */
thread1_entry(void * parameter)14*10465441SEvalZero static void thread1_entry(void* parameter)
15*10465441SEvalZero {
16*10465441SEvalZero /* 低优先级线程1开始运行 */
17*10465441SEvalZero rt_kprintf("thread1 startup%d\n");
18*10465441SEvalZero
19*10465441SEvalZero /* 挂起自身 */
20*10465441SEvalZero rt_kprintf("suspend thread self\n");
21*10465441SEvalZero rt_thread_suspend(tid1);
22*10465441SEvalZero /* 主动执行线程调度 */
23*10465441SEvalZero rt_schedule();
24*10465441SEvalZero
25*10465441SEvalZero /* 当线程1被唤醒时 */
26*10465441SEvalZero rt_kprintf("thread1 resumed\n");
27*10465441SEvalZero }
thread_cleanup(rt_thread_t tid)28*10465441SEvalZero static void thread_cleanup(rt_thread_t tid)
29*10465441SEvalZero {
30*10465441SEvalZero if (tid == tid1)
31*10465441SEvalZero {
32*10465441SEvalZero tid1 = RT_NULL;
33*10465441SEvalZero }
34*10465441SEvalZero if (tid == tid2)
35*10465441SEvalZero {
36*10465441SEvalZero tid = RT_NULL;
37*10465441SEvalZero }
38*10465441SEvalZero }
39*10465441SEvalZero
40*10465441SEvalZero /* 线程2入口 */
thread2_entry(void * parameter)41*10465441SEvalZero static void thread2_entry(void* parameter)
42*10465441SEvalZero {
43*10465441SEvalZero /* 延时10个OS Tick */
44*10465441SEvalZero rt_thread_delay(10);
45*10465441SEvalZero
46*10465441SEvalZero /* 唤醒线程1 */
47*10465441SEvalZero rt_thread_resume(tid1);
48*10465441SEvalZero rt_kprintf("thread2: to resume thread1\n");
49*10465441SEvalZero
50*10465441SEvalZero /* 延时10个OS Tick */
51*10465441SEvalZero rt_thread_delay(10);
52*10465441SEvalZero
53*10465441SEvalZero /* 线程2自动退出 */
54*10465441SEvalZero }
55*10465441SEvalZero
thread_resume_init()56*10465441SEvalZero int thread_resume_init()
57*10465441SEvalZero {
58*10465441SEvalZero /* 创建线程1 */
59*10465441SEvalZero tid1 = rt_thread_create("thread",
60*10465441SEvalZero thread1_entry, RT_NULL, /* 线程入口是thread1_entry, 入口参数是RT_NULL */
61*10465441SEvalZero THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
62*10465441SEvalZero if (tid1 != RT_NULL)
63*10465441SEvalZero {
64*10465441SEvalZero tid1->cleanup = thread_cleanup;
65*10465441SEvalZero rt_thread_startup(tid1);
66*10465441SEvalZero }
67*10465441SEvalZero else
68*10465441SEvalZero tc_stat(TC_STAT_END | TC_STAT_FAILED);
69*10465441SEvalZero
70*10465441SEvalZero /* 创建线程2 */
71*10465441SEvalZero tid2 = rt_thread_create("thread",
72*10465441SEvalZero thread2_entry, RT_NULL, /* 线程入口是thread2_entry, 入口参数是RT_NULL */
73*10465441SEvalZero THREAD_STACK_SIZE, THREAD_PRIORITY - 1, THREAD_TIMESLICE);
74*10465441SEvalZero if (tid2 != RT_NULL)
75*10465441SEvalZero {
76*10465441SEvalZero tid2->cleanup = thread_cleanup;
77*10465441SEvalZero rt_thread_startup(tid2);
78*10465441SEvalZero }
79*10465441SEvalZero else
80*10465441SEvalZero tc_stat(TC_STAT_END | TC_STAT_FAILED);
81*10465441SEvalZero
82*10465441SEvalZero return 0;
83*10465441SEvalZero }
84*10465441SEvalZero
85*10465441SEvalZero #ifdef RT_USING_TC
_tc_cleanup()86*10465441SEvalZero static void _tc_cleanup()
87*10465441SEvalZero {
88*10465441SEvalZero /* 调度器上锁，上锁后，将不再切换到其他线程，仅响应中断 */
89*10465441SEvalZero rt_enter_critical();
90*10465441SEvalZero
91*10465441SEvalZero /* 删除线程 */
92*10465441SEvalZero if (tid1 != RT_NULL && tid1->stat != RT_THREAD_CLOSE)
93*10465441SEvalZero rt_thread_delete(tid1);
94*10465441SEvalZero if (tid2 != RT_NULL && tid2->stat != RT_THREAD_CLOSE)
95*10465441SEvalZero rt_thread_delete(tid2);
96*10465441SEvalZero
97*10465441SEvalZero /* 调度器解锁 */
98*10465441SEvalZero rt_exit_critical();
99*10465441SEvalZero
100*10465441SEvalZero /* 设置TestCase状态 */
101*10465441SEvalZero tc_done(TC_STAT_PASSED);
102*10465441SEvalZero }
103*10465441SEvalZero
_tc_thread_resume()104*10465441SEvalZero int _tc_thread_resume()
105*10465441SEvalZero {
106*10465441SEvalZero /* 设置TestCase清理回调函数 */
107*10465441SEvalZero tc_cleanup(_tc_cleanup);
108*10465441SEvalZero thread_resume_init();
109*10465441SEvalZero
110*10465441SEvalZero /* 返回TestCase运行的最长时间 */
111*10465441SEvalZero return 25;
112*10465441SEvalZero }
113*10465441SEvalZero /* 输出函数命令到finsh shell中 */
114*10465441SEvalZero FINSH_FUNCTION_EXPORT(_tc_thread_resume, a thread resume example);
115*10465441SEvalZero #else
116*10465441SEvalZero /* 用户应用入口 */
rt_application_init()117*10465441SEvalZero int rt_application_init()
118*10465441SEvalZero {
119*10465441SEvalZero thread_resume_init();
120*10465441SEvalZero
121*10465441SEvalZero return 0;
122*10465441SEvalZero }
123*10465441SEvalZero #endif
124