1
0

thread_suspend.c 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. /*
  2. * 程序清单:挂起线程
  3. *
  4. * 这个例子中将创建两个动态线程,高优先级线程将在一定时刻后挂起低优先级线程。
  5. */
  6. #include <rtthread.h>
  7. #include "tc_comm.h"
  8. /* 指向线程控制块的指针 */
  9. static rt_thread_t tid1 = RT_NULL;
  10. static rt_thread_t tid2 = RT_NULL;
  11. /* 线程1入口 */
  12. static void thread1_entry(void* parameter)
  13. {
  14. rt_uint32_t count = 0;
  15. while (1)
  16. {
  17. /* 线程1采用低优先级运行,一直打印计数值 */
  18. rt_kprintf("thread count: %d\n", count ++);
  19. }
  20. }
  21. /* 线程2入口 */
  22. static void thread2_entry(void* parameter)
  23. {
  24. /* 延时10个OS Tick */
  25. rt_thread_delay(10);
  26. /* 挂起线程1 */
  27. rt_thread_suspend(tid1);
  28. /* 延时10个OS Tick */
  29. rt_thread_delay(10);
  30. /* 线程2自动退出 */
  31. }
  32. int thread_suspend_init()
  33. {
  34. /* 创建线程1 */
  35. tid1 = rt_thread_create("thread",
  36. thread1_entry, RT_NULL, /* 线程入口是thread1_entry, 入口参数是RT_NULL */
  37. THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
  38. if (tid1 != RT_NULL)
  39. rt_thread_startup(tid1);
  40. else
  41. tc_stat(TC_STAT_END | TC_STAT_FAILED);
  42. /* 创建线程2 */
  43. tid2 = rt_thread_create("thread",
  44. thread2_entry, RT_NULL, /* 线程入口是thread2_entry, 入口参数是RT_NULL */
  45. THREAD_STACK_SIZE, THREAD_PRIORITY - 1, THREAD_TIMESLICE);
  46. if (tid2 != RT_NULL)
  47. rt_thread_startup(tid2);
  48. else
  49. tc_stat(TC_STAT_END | TC_STAT_FAILED);
  50. return 0;
  51. }
  52. #ifdef RT_USING_TC
  53. static void _tc_cleanup()
  54. {
  55. /* 调度器上锁,上锁后,将不再切换到其他线程,仅响应中断 */
  56. rt_enter_critical();
  57. /* 删除线程 */
  58. if (tid1 != RT_NULL && tid1->stat != RT_THREAD_CLOSE)
  59. rt_thread_delete(tid1);
  60. if (tid2 != RT_NULL && tid2->stat != RT_THREAD_CLOSE)
  61. rt_thread_delete(tid2);
  62. /* 调度器解锁 */
  63. rt_exit_critical();
  64. /* 设置TestCase状态 */
  65. tc_done(TC_STAT_PASSED);
  66. }
  67. int _tc_thread_suspend()
  68. {
  69. /* 设置TestCase清理回调函数 */
  70. tc_cleanup(_tc_cleanup);
  71. thread_suspend_init();
  72. /* 返回TestCase运行的最长时间 */
  73. return 100;
  74. }
  75. /* 输出函数命令到finsh shell中 */
  76. FINSH_FUNCTION_EXPORT(_tc_thread_suspend, a thread suspend example);
  77. #else
  78. /* 用户应用入口 */
  79. int rt_application_init()
  80. {
  81. thread_suspend_init();
  82. return 0;
  83. }
  84. #endif