-module(server_templat
-export([start/1]).
-export([call/2, cast/2]).
-export([init/1]).%%通用进程模式（可以认为是c/s模型的阻塞和非阻塞）start(Mod) ->spawn(server_template, init, [Mod]).
init(Mod) ->register(Mod, self()),State = Mod:init(),loop(Mod, State).loop(Mod, State) ->receive{call, From, Req} ->{Res, State2} = Mod:handle_call(Req, State),From ! {Mod, Res},loop(Mod, State2);{cast, Req} ->State2 = Mod:handle_cast(Req, State),loop(Mod, State2);stop ->   stop   end.%% 接口部分
call(Name, Req) ->Name ! {call, self(), Req},receive             %% 这里就是阻塞在等待返回，精辟！！！{Name, Res} ->Resend.
cast(Name, Req) ->Name ! {cast, Req},ok.

package globalimport ("time"
)type PidObj struct {Callback GenServerreqCh   chan GenReqreplyCh chan Replystop bool
}type GenReq struct {Method stringMsgData interface{}t inttime int32
}type Reply interface{}const (call = iotacasttimershutdown
)// Start server
func RegisterPid(pidName interface{}, callback GenServer) *PidObj {pidObj := &PidObj{Callback:callback}pidObj.reqCh = make(chan GenReq, 1024)pidObj.replyCh = make(chan Reply, 1024)callback.Start()go pidObj.loop()return pidObj
}func (p *PidObj) loop() {for {req := <-p.reqChswitch req.t {case call:reply := p.Callback.HandleCall(req)p.replyCh <- replycase cast:p.Callback.HandleCast(req)case timer:p.Callback.HandleInfo(req)//time.AfterFunc(time.Duration(req.time) * time.Second, func() {// p.Callback.HandleInfo(req)//})case shutdown:p.stop = trueclose(p.reqCh)close(p.replyCh)p.Callback.Stop()return}}
}func (p *PidObj) Call(method string, msg interface{}) (reply Reply) {p.reqCh <- GenReq{Method: method, MsgData: msg, t: call}reply = <-p.replyChreturn
}func (p *PidObj) Cast(method string, msg interface{}) {p.reqCh <- GenReq{Method: method, MsgData: msg, t: cast}
}func (p *PidObj) SendAfter(method string, seconds int32, msg interface{}) {time.AfterFunc(time.Duration(seconds) * time.Second, func() {if !p.stop {p.reqCh <- GenReq{Method: method, MsgData: msg, t: timer, time:seconds}}})
}func (p *PidObj) Stop() {p.reqCh <- GenReq{t: shutdown}
}

package global// GenServer behavior needs to implement this interface
type GenServer interface {Start()HandleCall(GenReq) ReplyHandleCast(GenReq)HandleInfo(GenReq)Stop()
}