xt_task.h

浏览该文件的文档.

 
#ifndef __XT_TASK_H__
#define __XT_TASK_H__
 
/* ==================== [Includes] ========================================== */
 
#include "xtiny.h"
#if (XT_TASK_ENABLE_OS)
#include "cmsis_os2.h"
#endif
#include "xt_timer2.h"
#include "xt_event.h"
 
#ifdef __cplusplus
extern "C" {
#endif

 
/* ==================== [Defines] =========================================== */

#define XT_TASK_INLIVAD_ID        0xff

#define XT_TASK_WAIT_FOREVER      0xffffffff

#define XT_TASK_LC_INIT_VALUE     0

#define xt_task_lc_init(s)        s = XT_TASK_LC_INIT_VALUE;

#define xt_task_lc_resume(s)      switch(s) { case XT_TASK_LC_INIT_VALUE:

#define _xt_task_lc_set(s)        s = __LINE__; case __LINE__:

#define xt_task_lc_end(s)         default:; break; }
 
/* ==================== [Typedefs] ========================================== */

typedef void (*xt_task_entry_t)(void *user_data);

typedef struct xt_task xt_task_t;

struct xt_task {
    xt_task_entry_t   entry;        
    void             *user_data;    
    volatile int      lc;           
    xt_timer2_t       timer;        
    xt_event_id_t     wait_event;   
    uint8_t           task_id;      
    uint8_t           parent_id;    
};
 
/* ==================== [Global Prototypes] ================================= */


xt_err_t xt_task_setup(void);

xt_task_t *xt_task_start(xt_task_entry_t entry, void *user_data);

xt_task_t *xt_task_running(void);

bool xt_task_is_running(xt_task_t *task);

void xt_task_sys_reset(void);
  /* 任务生命周期与控制 */
 
/* ---- 内部 API（用户不应直接调用） ---- */

void xt_task_timer_start(uint32_t timeout_ms);

void xt_task_event_subscribe(xt_event_id_t event_id, uint32_t timeout_ms);

void xt_task_event_handler(xt_event_id_t event_id);
 
/* ==================== [Macros] ============================================ */

#define XT_TASK_BEGIN() \
    _Pragma("GCC diagnostic push") \
    _Pragma("GCC diagnostic ignored \"-Wimplicit-fallthrough\"") \
    { char XT_TASK_YIELD_FLAG = 1; (void)XT_TASK_YIELD_FLAG; xt_task_lc_resume(xt_task_running()->lc)

#define XT_TASK_END() \
    xt_task_lc_end(); xt_task_lc_init(xt_task_running()->lc);} \
    _Pragma("GCC diagnostic pop")

#define xt_task_delay(ms) \
    do { \
        xt_task_timer_start(ms); \
        XT_TASK_YIELD_FLAG = 0; \
        _xt_task_lc_set(xt_task_running()->lc); \
        if (XT_TASK_YIELD_FLAG == 0) { \
            return; \
        } \
    } while(0)

#define xt_task_wait_event(event_id, event_param) \
    do { \
        xt_task_event_subscribe(event_id, XT_TASK_WAIT_FOREVER); \
        XT_TASK_YIELD_FLAG = 0; \
        _xt_task_lc_set(xt_task_running()->lc); \
        if (XT_TASK_YIELD_FLAG == 0) { \
            return; \
        } \
        event_param = xt_event_get_current_event_param(); \
    } while(0)

#define xt_task_wait_until(event_id, timeout) \
    do { \
        xt_task_event_subscribe(event_id, timeout); \
        XT_TASK_YIELD_FLAG = 0; \
        _xt_task_lc_set((xt_task_running()->lc)); \
        if (XT_TASK_YIELD_FLAG == 0) { \
            return; \
        } \
    } while(0)

#define xt_task_call_subtask(entry, user_data) \
    do { \
        xt_task_t *__sub = xt_task_start(entry, user_data); \
        if (__sub == NULL) { \
            break; \
        } \
        XT_TASK_YIELD_FLAG = 0; \
        _xt_task_lc_set((xt_task_running()->lc)); \
        if (XT_TASK_YIELD_FLAG == 0) { \
            return; \
        } \
    } while(0)
  /* xt_task */
 
#ifdef __cplusplus
} /* extern "C" */
#endif
 
#endif /* __XT_TASK_H__ */