mutex_simple.c 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. /*
  2. * 程序清单:
  3. */
  4. #include <rtthread.h>
  5. #include "tc_comm.h"
  6. /* 指向线程控制块的指针 */
  7. static rt_thread_t tid1 = RT_NULL;
  8. static rt_thread_t tid2 = RT_NULL;
  9. static rt_thread_t tid3 = RT_NULL;
  10. /* 线程1入口 */
  11. static void thread1_entry(void* parameter)
  12. {
  13. while (1)
  14. {
  15. }
  16. }
  17. /* 线程2入口 */
  18. static void thread2_entry(void* parameter)
  19. {
  20. while (1)
  21. {
  22. }
  23. }
  24. /* 线程3入口 */
  25. static void thread3_entry(void* parameter)
  26. {
  27. while (1)
  28. {
  29. }
  30. }
  31. int mutex_simple_init()
  32. {
  33. /* 创建线程1 */
  34. tid1 = rt_thread_create("t1",
  35. thread1_entry, RT_NULL, /* 线程入口是thread1_entry, 入口参数是RT_NULL */
  36. THREAD_STACK_SIZE, THREAD_PRIORITY - 1, THREAD_TIMESLICE);
  37. if (tid1 != RT_NULL)
  38. rt_thread_startup(tid1);
  39. else
  40. tc_stat(TC_STAT_END | TC_STAT_FAILED);
  41. /* 创建线程2 */
  42. tid2 = rt_thread_create("t2",
  43. thread2_entry, RT_NULL, /* 线程入口是thread2_entry, 入口参数是RT_NULL */
  44. THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE);
  45. if (tid2 != RT_NULL)
  46. rt_thread_startup(tid2);
  47. else
  48. tc_stat(TC_STAT_END | TC_STAT_FAILED);
  49. /* 创建线程3 */
  50. tid3 = rt_thread_create("t3",
  51. thread3_entry, RT_NULL, /* 线程入口是thread3_entry, 入口参数是RT_NULL */
  52. THREAD_STACK_SIZE, THREAD_PRIORITY + 1, THREAD_TIMESLICE);
  53. if (tid3 != RT_NULL)
  54. rt_thread_startup(tid3);
  55. else
  56. tc_stat(TC_STAT_END | TC_STAT_FAILED);
  57. return 0;
  58. }
  59. #ifdef RT_USING_TC
  60. static void _tc_cleanup()
  61. {
  62. /* 调度器上锁,上锁后,将不再切换到其他线程,仅响应中断 */
  63. rt_enter_critical();
  64. /* 删除线程 */
  65. if (tid1 != RT_NULL && tid1->stat != RT_THREAD_CLOSE)
  66. rt_thread_delete(tid1);
  67. if (tid2 != RT_NULL && tid2->stat != RT_THREAD_CLOSE)
  68. rt_thread_delete(tid2);
  69. if (tid3 != RT_NULL && tid3->stat != RT_THREAD_CLOSE)
  70. rt_thread_delete(tid3);
  71. /* 调度器解锁 */
  72. rt_exit_critical();
  73. /* 设置TestCase状态 */
  74. tc_done(TC_STAT_PASSED);
  75. }
  76. int _tc_mutex_simple()
  77. {
  78. /* 设置TestCase清理回调函数 */
  79. tc_cleanup(_tc_cleanup);
  80. mutex_simple_init();
  81. /* 返回TestCase运行的最长时间 */
  82. return 100;
  83. }
  84. /* 输出函数命令到finsh shell中 */
  85. FINSH_FUNCTION_EXPORT(_tc_mutex_simple, sime mutex example);
  86. #else
  87. /* 用户应用入口 */
  88. int rt_application_init()
  89. {
  90. mutex_simple_init();
  91. return 0;
  92. }
  93. #endif