1 /* 2 * 程序清单：删除线程 3 * 4 * 这个例子会创建两个线程，在一个线程中删除另外一个线程。 5 */ 6 #include <rtthread.h> 7 #include "tc_comm.h" 8 9 /* 10 * 线程删除(rt_thread_delete)函数仅适合于动态线程，为了在一个线程 11 * 中访问另一个线程的控制块，所以把线程块指针声明成全局类型以供全 12 * 局访问 13 */ 14 static rt_thread_t tid1 = RT_NULL, tid2 = RT_NULL; 15 /* 线程1的入口函数 */ 16 static void thread1_entry(void* parameter) 17 { 18 rt_uint32_t count = 0; 19 20 while (1) 21 { 22 /* 线程1采用低优先级运行，一直打印计数值 */ 23 // rt_kprintf("thread count: %d\n", count ++); 24 count ++; 25 } 26 } 27 static void thread1_cleanup(struct rt_thread *tid) 28 { 29 if (tid != tid1) 30 { 31 tc_stat(TC_STAT_END | TC_STAT_FAILED); 32 return ; 33 } 34 rt_kprintf("thread1 end\n"); 35 tid1 = RT_NULL; 36 } 37 38 /* 线程2的入口函数 */ 39 static void thread2_entry(void* parameter) 40 { 41 /* 线程2拥有较高的优先级，以抢占线程1而获得执行 */ 42 43 /* 线程2启动后先睡眠10个OS Tick */ 44 rt_thread_delay(RT_TICK_PER_SECOND); 45 46 /* 47 * 线程2唤醒后直接删除线程1，删除线程1后，线程1自动脱离就绪线程 48 * 队列 49 */ 50 rt_thread_delete(tid1); 51 52 /* 53 * 线程2继续休眠10个OS Tick然后退出，线程2休眠后应切换到idle线程 54 * idle线程将执行真正的线程1控制块和线程栈的删除 55 */ 56 rt_thread_delay(RT_TICK_PER_SECOND); 57 } 58 59 static void thread2_cleanup(struct rt_thread *tid) 60 { 61 /* 62 * 线程2运行结束后也将自动被删除(线程控制块和线程栈在idle线 63 * 程中释放) 64 */ 65 66 if (tid != tid2) 67 { 68 tc_stat(TC_STAT_END | TC_STAT_FAILED); 69 return ; 70 } 71 rt_kprintf("thread2 end\n"); 72 tid2 = RT_NULL; 73 tc_done(TC_STAT_PASSED); 74 } 75 76 /* 线程删除示例的初始化 */ 77 int thread_delete_init() 78 { 79 /* 创建线程1 */ 80 tid1 = rt_thread_create("t1", /* 线程1的名称是t1 */ 81 thread1_entry, RT_NULL, /* 入口是thread1_entry，参数是RT_NULL */ 82 THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE); 83 if (tid1 != RT_NULL) /* 如果获得线程控制块，启动这个线程 */ 84 { 85 tid1->cleanup = thread1_cleanup; 86 rt_thread_startup(tid1); 87 } 88 else 89 tc_stat(TC_STAT_END | TC_STAT_FAILED); 90 91 /* 创建线程1 */ 92 tid2 = rt_thread_create("t2", /* 线程1的名称是t2 */ 93 thread2_entry, RT_NULL, /* 入口是thread2_entry，参数是RT_NULL */ 94 THREAD_STACK_SIZE, THREAD_PRIORITY - 1, THREAD_TIMESLICE); 95 if (tid2 != RT_NULL) /* 如果获得线程控制块，启动这个线程 */ 96 { 97 tid2->cleanup = thread2_cleanup; 98 rt_thread_startup(tid2); 99 } 100 else 101 tc_stat(TC_STAT_END | TC_STAT_FAILED); 102 103 return 10 * RT_TICK_PER_SECOND; 104 } 105 106 #ifdef RT_USING_TC 107 static void _tc_cleanup() 108 { 109 /* lock scheduler */ 110 rt_enter_critical(); 111 112 /* delete thread */ 113 if (tid1 != RT_NULL) 114 { 115 rt_kprintf("tid1 is %p, should be NULL\n", tid1); 116 tc_stat(TC_STAT_FAILED); 117 } 118 if (tid2 != RT_NULL) 119 { 120 rt_kprintf("tid2 is %p, should be NULL\n", tid2); 121 tc_stat(TC_STAT_FAILED); 122 } 123 124 /* unlock scheduler */ 125 rt_exit_critical(); 126 } 127 128 int _tc_thread_delete() 129 { 130 /* set tc cleanup */ 131 tc_cleanup(_tc_cleanup); 132 return thread_delete_init(); 133 } 134 FINSH_FUNCTION_EXPORT(_tc_thread_delete, a thread delete example); 135 #else 136 int rt_application_init() 137 { 138 thread_delete_init(); 139 140 return 0; 141 } 142 #endif 143