从零开始漫谈 | 多实例的状态机
扫描二维码
随时随地手机看文章
比如下面这个状态图就是一个典型:
通过图示,我们能清晰的看出该状态机实现的是“通用字符串输出”的功能。其实,这里我算是埋下了一个小小的“彩蛋”——当然,它的真实身份是一个陷阱。如果你已经熟悉了我前面介绍的翻译规则,很容易就会发现这里存在的巨大问题:是的,这个状态图按照switch翻译法无脑翻译的后果,将是一个根本无法正常工作的状态机:
typedef enum { fsm_rt_err = -1, fsm_rt_on_going = 0, fsm_rt_cpl = 1,} fsm_rt_t;
extern bool serial_out(uint8_t chByte);
#define PRINT_STR_RESET_FSM() \ do { s_tState = START; } while(0)
fsm_rt_t print_str(const char *pchStr){ static enum { START = 0, IS_END_OF_STRING, SEND_CHAR, } s_tState = START;
switch (s_tState) { case START: s_tState = IS_END_OF_STRING; break; case IS_END_OF_STRING: if (*pchStr == '\0') { PRINT_STR_RESET_FSM(); return fsm_rt_cpl; } s_tState = SEND_CHAR; break; case SEND_CHAR: if (serial_out(*pchStr)) { pchStr ; s_tState = IS_END_OF_STRING; } break; }
return fsm_rt_on_going;} 不仔细看的小伙伴也许会挠挠后脑勺,说:“代码很漂亮……但我也没看出有啥问题啊”?
不打紧,我们来看看这个状态机时如何使用的:
print_str(c_tDemoStr); }} 还没看出问题么?
-
pchStr是一个局部变量,它保存了状态机函数 print_str 被调用时用户所传递的字符串首地址;
-
该状态机在执行的过程中,不可避免的要多次出让(Yield)处理器时间,以达到“非阻塞”的目的;
-
由于pchStr是一个局部变量,它的生命周期在退出print_str函数后就结束了;而每次重新进入print_str函数,它的值都会被复位成“hello world\r\n”的起始地址。
既然问题清楚了,修改方式也迎刃而解,如下图所示:
也就是说,我们可以通过引入一个静态变量 s_pchStr的方式来保存状态机的关键上下文信息。对比图片,可以注意到:修改后的图在复位后的初始化阶段(也就是start的行为部分)对静态变量 s_pchStr做了一个初始化——用pchStr为其赋值。此后,图中所有针对字符串的操作也都是使用 s_pchStr 来完成了。
重新翻译后的代码如下:
switch (s_tState) { case START: s_pchStr = pchStr; s_tState = IS_END_OF_STRING; //break; //!< fall-through case IS_END_OF_STRING: if (*s_pchStr == '\0') { PRINT_STR_RESET_FSM(); return fsm_rt_cpl; } s_tState = SEND_CHAR; //break; //!< fall-through case SEND_CHAR: if (serial_out(*s_pchStr)) { pchStr ; s_tState = IS_END_OF_STRING; } break; }
return fsm_rt_on_going;}
【一系列似是而非的问题……】
-
状态机print_str 使用了静态变量来保存状态(s_tState)和关键的上下文(s_pchStr),因此几乎肯定是不可重入的;
-
状态机print_str使用了共享函数serial_out(),即便该函数本身可以保证原子性,但它仍然是一个临界资源——换句话说,即便抛开 print_str 的可重入性问题不谈,当有该状态机存在多个实例时,你能保证每个字符串的打印都是完整的么?比如:
此时,我们可以说,print_str 也不是线程安全(thread-safe)的。
根据维基百科的描述:
In computing, ... a reentrant procedure can be interrupted in the middle of its execution and then safely be called again ("re-entered") before its previous invocations complete execution.大体翻译成中文就是:https://en.wikipedia.org/wiki/Reentrancy_(computing)
这里,我们需要注意一个细节,就是“可重入”关注的是,在任意时刻,无论以什么样的方式,该函数被多次调用时是否“安全”。换句话说,它并不是“非常在意”可重入本身对功能的影响,它在意的是这样调用是否“安全”。
以我们的print_str为例,由于状态机的中使用了静态变量,尤其是状态变量s_tState——这意味着同时执行的多个实例,彼此共享同一个状态变量……换句话说,当多个print_str同时执行时,它们是彼此干扰的。这意味着同时执行多个print_str是“不安全”的,是会出问题的(比如字符串长度不一致时很可能会出现buffer-overflow的问题),因此可以说 print_str 是不可重入的。
但换一个角度,假设我们已经解决了print_str的不可重入问题,比如:妥善的解决了状态变量和上下文的存储问题,那么就满足了“可重入”关于“安全”的要求——因为当存在多个实例的时候,这样执行并不会导致系统崩溃,或是buffer-overflow——只不过打印出来的字符串并不完整而已。这就是为什么人们常说的:
可重入的函数不一定线程安全;
本质上,我们要解决的并不单纯是状态机的“可重入”问题——只把眼光放在可重入上就“格局小了”。
【多实例的状态机】
通过前面的分析,我们已经注意到了问题所在,即:以现有的实现方式,如果存在多个 print_str 调用(实例),那么它们其实是在“竞争”关键的状态变量 s_tState和上下文 s_pchStr。
聪明的你一定看出来了,解决状态机多实例的方式就是“给每个实例都发一个球”。具体来说,就是:
-
为状态机定义一个控制块;
-
在控制块里存放状态变量;
-
在控制块里存放状态机的上下文;
-
建立状态机实例时,首先要建立一个控制块,并对其进行必要的初始化;
-
在随后调用状态机时,应该首先传递状态机的控制块给状态机函数。
对应到图例上,我们一般会在状态图的某个角落(比如左下角或右下角)通过一个矩形框列举状态机上下文的所有内容。如下图所示:
观察修改后的状态图,我们应该注意以下的一些变化:
-
在图的右下角,出现了一个带标题的矩形框。这里标题print_str_t是状态机控制块的类型名称;下面的列表中列举了上下文的内容,在本例中就是 pchStr,注意,它已经去掉了"s_"前缀。
-
状态图中通过 "this.xxxx" 的方式来访问状态机上下文中的内容。
【基本的翻译方法】
int <状态机名称>_init(<状态机类型名称> *ptThis[, <形参列表>]){ ... this.chState = 0; //!< 复位状态变量,这里固定用0 /*! \note 这里根据需要可以初始化那些只需要初始化一次的上下文 */ /*! \note 这里也可以对输入的参数进行有效性检测,如果发现错误, *! 就返回负数值。这里既可以自定义一套枚举,也可以简单 *! 返回 -1 了事。 */ return 0; //!< 如果一切顺利返回0,表示正常} 以 print_str为例:
接下来,我们就需要对状态机函数进行小小的改造,其格式为:
fsm_rt_t <状态机名称>(<状态机类型名> *ptThis[, <形参列表>]){ //!< 这种事情就不适合在release版本的运行时刻检查 assert(NULL != ptThis); enum { START = 0, <状态列表> }; ... switch (this.chState) { ... } return fsm_rt_on_going;}
#define PRINT_STR_RESET_FSM() \ do { this.State = START; } while(0)
fsm_rt_t print_str(print_str_t *ptThis, const char *pchStr){ enum { START = 0, IS_END_OF_STRING, SEND_CHAR, };
switch (this.chState) { case START: this.pchStr = pchStr; this.chState = IS_END_OF_STRING; //break; //!< fall-through case IS_END_OF_STRING: if (*(this.pchStr) == '\0') { PRINT_STR_RESET_FSM(); return fsm_rt_cpl; } this.chState = SEND_CHAR; //break; //!< fall-through case SEND_CHAR: if (serial_out(*(this.pchStr))) { this.pchStr ; this.chState = IS_END_OF_STRING; } break; }
return fsm_rt_on_going;} 此时,我们就可以“安全”的进行多实例调用了:
int main(void){ ... print_str_init(