TimeScheduleSystem.c 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219
  1. /************************************/
  2. /* @Author: @woshiashuai */
  3. /* @Version: V1.0 */
  4. /* @Date: 2023-02-12 13:06:48 */
  5. /* @Description: */
  6. /* V1.0: create */
  7. /************************************/
  8. #include "TimeScheduleSystem.h"
  9. TSS_t *TSS_head = NULL; // 分时调度系统工作链表头节点
  10. /**
  11. * @brief 分时调度事件初始化 加入到初始化中
  12. * @param TSS: 事件指针
  13. * @param targetTicks: 目标计数值 = 事件调度周期 / 调度器周期 例如: 100 = 500ms / 5ms
  14. * @param callback: 事件回调函数
  15. * @retval 0: 初始化成功 1: 参数二为零 2: 参数三为空 3: 事件已存在
  16. */
  17. unsigned char TSS_init(TSS_t *TSS, unsigned int targetTicks, void (* callback)(void))
  18. {
  19. if(targetTicks == 0) return 1;
  20. if(callback == NULL) return 2;
  21. memset(TSS, 0, sizeof(TSS_t));
  22. TSS->targetTicks = targetTicks;
  23. TSS->callback = callback;
  24. TSS_t *TSS_target = TSS_head;
  25. while(TSS_target) {
  26. if(TSS_target == TSS) return 3;
  27. TSS_target = TSS_target->next;
  28. }
  29. TSS->state = 1; // 加入工作链表则改变状态为在工作链表
  30. TSS->next = TSS_head;
  31. TSS_head = TSS;
  32. return 0;
  33. }
  34. /**
  35. * @brief 分时调度事件循环处理的内部方法
  36. * @param TSS: 事件指针
  37. * @retval None
  38. */
  39. static void TSS_whileHandle(TSS_t *TSS)
  40. {
  41. // 分时调度结果是可执行
  42. if(TSS->result) {
  43. TSS->callback(); // 执行绑定的回调函数
  44. TSS->ticks = 0; // 防止因手动切换状态导致的ticks不为0
  45. TSS->result = 0; // 切换分时调度结果为等待中
  46. }
  47. }
  48. /**
  49. * @brief 分时调度事件循环处理 加入到主循环中
  50. * @param None
  51. * @retval None
  52. */
  53. void TSS_while(void)
  54. {
  55. TSS_t *TSS_target;
  56. for(TSS_target = TSS_head; TSS_target; TSS_target = TSS_target->next) {
  57. TSS_whileHandle(TSS_target);
  58. }
  59. }
  60. /**
  61. * @brief 分时调度事件调度处理的内部方法
  62. * @param TSS: 事件指针
  63. * @retval None
  64. */
  65. static void TSS_timerHandle(TSS_t *TSS)
  66. {
  67. // 分时调度结果是等待中
  68. if(!TSS->result) {
  69. TSS->ticks += 1; // 计数自加
  70. // 计数大于等于目标计数
  71. if(TSS->ticks >= TSS->targetTicks) {
  72. TSS->ticks = 0; // 计数清零
  73. TSS->result = 1; // 切换分时调度结果为可执行
  74. }
  75. }
  76. }
  77. /**
  78. * @brief 分时调度事件调度处理 加入到调度器中
  79. * @param None
  80. * @retval None
  81. */
  82. void TSS_timer(void)
  83. {
  84. TSS_t *TSS_target;
  85. for(TSS_target = TSS_head; TSS_target; TSS_target = TSS_target->next) {
  86. TSS_timerHandle(TSS_target);
  87. }
  88. }
  89. /**
  90. * @brief 分时调度事件挂起处理 将事件从工作链表中去掉
  91. * @param TSS: 事件指针
  92. * @retval 0: 挂起成功 1: 事件未初始化/初始化失败 2: 事件不在工作链表中(可能已被挂起)
  93. */
  94. unsigned char TSS_pending(TSS_t *TSS)
  95. {
  96. if((TSS->targetTicks == 0) || (TSS->callback == NULL) || (TSS->next == NULL)) return 1;
  97. TSS_t *TSS_target = TSS_head;
  98. TSS_t *TSS_last = NULL;
  99. while(TSS_target) {
  100. // 查找事件是否存在
  101. if(TSS_target == TSS) {
  102. // 是否在头节点
  103. if(TSS_last == NULL) {
  104. TSS_head = TSS_target->next; // 在头节点则将下一个节点作为新的头节点
  105. } else {
  106. // 不在头节点则将下一个节点链接到上一个节点
  107. TSS_last->next = TSS_target->next;
  108. TSS_head = TSS_last;
  109. }
  110. TSS->state = 0; // 退出工作链表则改变状态为不在工作链表
  111. return 0;
  112. }
  113. TSS_last = TSS_target;
  114. TSS_target = TSS_target->next;
  115. }
  116. return 2;
  117. }
  118. /**
  119. * @brief 分时调度事件恢复处理
  120. * @param TSS: 事件指针
  121. * @retval 0: 恢复成功 1: 事件未初始化/初始化失败 2: 事件已在工作链表中(可能已被恢复)
  122. */
  123. unsigned char TSS_resume(TSS_t *TSS)
  124. {
  125. if((TSS->targetTicks == 0) || (TSS->callback == NULL) || (TSS->next == NULL)) return 1;
  126. TSS_t *TSS_target = TSS_head;
  127. while(TSS_target) {
  128. if(TSS_target == TSS) return 2;
  129. TSS_target = TSS_target->next;
  130. }
  131. TSS->state = 1; // 加入工作链表则改变状态为在工作链表
  132. TSS->next = TSS_head;
  133. TSS_head = TSS;
  134. return 0;
  135. }
  136. /**
  137. * @brief 分时调度事件设置计数值处理
  138. * @param TSS: 事件指针
  139. * @param ticks: 设置的计数值
  140. * @retval None
  141. */
  142. void TSS_setTicks(TSS_t *TSS, unsigned char ticks)
  143. {
  144. TSS->ticks = ticks;
  145. }
  146. /**
  147. * @brief 分时调度事件获取计数值处理
  148. * @param TSS: 事件指针
  149. * @retval 事件计数值
  150. */
  151. unsigned int TSS_getTicks(TSS_t *TSS)
  152. {
  153. return TSS->ticks;
  154. }
  155. /**
  156. * @brief 分时调度事件设置目标计数值处理 主要用于修改事件执行周期,若较上次改小则可能立即触发事件执行
  157. * @param TSS: 事件指针
  158. * @param result: 设置的目标计数值
  159. * @retval None
  160. */
  161. void TSS_setTargetTicks(TSS_t *TSS, unsigned char targetTicks)
  162. {
  163. TSS->targetTicks = targetTicks;
  164. }
  165. /**
  166. * @brief 分时调度事件获取目标计数值处理 主要用于查看事件执行周期
  167. * @param TSS: 事件指针
  168. * @retval 事件目标计数值
  169. */
  170. unsigned int TSS_TargetTicks(TSS_t *TSS)
  171. {
  172. return TSS->targetTicks;
  173. }
  174. /**
  175. * @brief 分时调度事件设置结果值处理 主要用于立即切换事件结果为1:可执行
  176. * @param TSS: 事件指针
  177. * @param result: 设置的结果值
  178. * @retval None
  179. */
  180. void TSS_setResult(TSS_t *TSS, unsigned char result)
  181. {
  182. TSS->result = result;
  183. }
  184. /**
  185. * @brief 分时调度事件获取结果值处理 一般获取到的事件结果多为0:等待中,因为事件执行后即清零
  186. * @param TSS: 事件指针
  187. * @retval 事件结果值 0: 等待中 1: 可执行
  188. */
  189. unsigned char TSS_getResult(TSS_t *TSS)
  190. {
  191. return TSS->result;
  192. }
  193. /**
  194. * @brief 分时调度事件设置状态值处理 手动操作此函数无效,因为事件状态只与事件是否存在于工作链表中有关
  195. * @param TSS: 事件指针
  196. * @param state: 设置的状态值
  197. * @retval None
  198. */
  199. void TSS_setState(TSS_t *TSS, unsigned char state)
  200. {
  201. // TSS->state = state;
  202. }
  203. /**
  204. * @brief 分时调度事件获取状态值处理 主要用于查看事件是否存在于工作链表中
  205. * @param TSS: 事件指针
  206. * @retval 事件的状态值 0:不在工作链表 1:在工作链表
  207. */
  208. unsigned char TSS_getState(TSS_t *TSS)
  209. {
  210. return TSS->state;
  211. }