erlang - 为什么这个 gen_statem 调用阻塞?
问题描述
您好,我想弄清楚何时使用gen_statem
为什么会阻止调用,因为我的 fsm 在单独的进程中运行。
-module(fsm).
-record(data,{
current="None",
intvCount=0,
jobCount=0
}).
-export([init/1,terminate/3,callback_mode/0,code_change/4]).
-export([state/1,start/0,interview/2,reject/2,wait/1]).
-export([sitting_home/3,interviewing/3]).
-export([handle_event/3]).
-behaviour(gen_statem).
handle_event({call,From},get_state,Data)->
io:format("why you need state>"),
{keep_state,Data};
handle_event({call,From},Event,Data)->
{keep,state,Data}.
%API
start()->
gen_statem:start_link(?MODULE,[],[]).
state(PID)->
gen_statem:call(PID,get_state).
interview(PID,Company)->
gen_statem:call(PID,{intv,Company}).
reject(PID,Company)->
gen_statem:call(PID,{reject,Company}).
wait(PID)->
gen_statem:call(PID,{wait}).
%mandatory
code_change(V,State,Data,Extra)->{ok,State,Data}.
callback_mode() ->
state_functions.
init([])->
{ok,sitting_home,#data{current="None",jobCount=0,intvCount=0}}.
terminate(Reasom,State,Data)->
void.
% State implementations
sitting_home({call,From},{intv,Company},Data=#data{intvCount=C})->
io:format("called for interview"),
{next_state,interviewing,Data#data{intvCount=C+1},{reply,From,something}};
sitting_home({call,From},Event,Data)->
{keep_state,Data}.
interviewing({call,From},{rejected,Company},Data)->
{next_state,sitting_home,Data,{reply,From,somethingelse}};
interviewing({call,From},wait,Data)->
{keep_state,Data}.
用法:
>{ok,Pid}=fsm:start().
>fsm:state(). //blocks !
>{ok,Pid}=fsm:start().
>fsm:interview(Pid).
called for interview %and blocks
为什么两个调用都会阻塞?除了fsm
使用gen_statem:start_link
. 为什么在这两种情况下都会阻塞?
更新
在有人指出我忘记使用reply
以将某些内容发回给调用者之后,我已经更新了我的帖子。handle_event/3
但是即使以这种形式仍然会阻塞:
handle_event({call,From},get_state,Data)->
{keep_state,Data,[{reply,From,Data}]}.
解决方案
因为这就是gen_statem:call
:
通过发送请求并等待其回复到达,对 gen_statem ServerRef进行同步调用
并且您的状态功能不会发送任何回复。他们应该看起来像
sitting_home({call,From},{intv,Company},Data=#data{intvCount=C})->
io:format("called for interview"),
{next_state,interviewing,Data#data{intvCount=C+1},{reply,From,WhateverReplyYouWant}};
或者
sitting_home({call,From},{intv,Company},Data=#data{intvCount=C})->
io:format("called for interview"),
gen_statem:reply(From, WhateverReplyYouWant),
{next_state,interviewing,Data#data{intvCount=C+1}};
如果没有有用的回复,请考虑
使用
cast
而不是call
(并在您的状态函数中处理cast
)EventType
,或ok
作为答复。
推荐阅读
- html - 如何继承某个位置(CSS)
- java - 如何配置.gitignore文件不推送某个json文件到git
- windows - 从 Windows 10(和任何其他 Appxpackage)中删除 Webp 图像扩展
- c# - 如何使用 LINQ 有条件地创建新的字符串数组?
- angular - 无法从角度拦截器获取请求标头
- javascript - 将javascript中的对象打印到html dom中
- javascript - Javascript - 如何检查字符串是否包含转义序列
- android - 生命周期从不通过 onCreate
- jython - Maximo 脚本向另一个用户发送消息?
- arrays - 如何使用 qsort 对结构指针数组进行排序