gen_server的同步调用内部实现机制及From的前世今生
2015-02-13 07:30
351 查看
1、同步调用
首先客户端进程通过call向gen_server发起同步调用,客户端进程会monitor向gen_server进程,返回一个监控句柄Mref,同时向gen_server进程发送{Label,{self(),Mref},Request}后,客户端进程执行receive便进入阻塞状态,等待对应消息的到来。gen_server进程收到客户端发来的消息对其进行解析,解析出{self(),Mref}=From,即From是由客户端进程和客户端进程对gen_server的monitor句柄组成的一个元组,是客户端进程将自己的进程id发送给gen_server,gen_server解析出来后传给实现gen_server行为模式的同步回调接口,这就是From的前世今生,回调部分接口是在gen_server进程内部执行,通用部分接口是在客户端进程中执行。
客户端进程一直在侦听消息的到来,如果收到了同步调用的返回值,客户端进程是这样做的,首先执行demonitor解除与gen_server的监控关系,进而将结果返回,客户端进程从receive的阻塞状态跳出来,对外表现为同步调用返回;如果收到gen_server进程发来的{'DOWN',Mref,_,_,Reason}消息,客户端进程马上exit;如果timeout时间后依旧没有没有收到结果,便自动demonitor后,退出。
总结:1、erlang底层之所以让客户端进程单向monitor目标gen_server进程,就是想在同步调用过程,让客户端与gen_server进程有个“握手-分手”的过程,一旦gen_server进程挂了,客户端进程能够收到DOWN消息,进而客户端进程退出;
2、当进程A与进程B既有link关系,又有A到B的monitor时,一旦B进程挂了,exit退出信号会优先‘DOWN’发给进程A。
首先客户端进程通过call向gen_server发起同步调用,客户端进程会monitor向gen_server进程,返回一个监控句柄Mref,同时向gen_server进程发送{Label,{self(),Mref},Request}后,客户端进程执行receive便进入阻塞状态,等待对应消息的到来。gen_server进程收到客户端发来的消息对其进行解析,解析出{self(),Mref}=From,即From是由客户端进程和客户端进程对gen_server的monitor句柄组成的一个元组,是客户端进程将自己的进程id发送给gen_server,gen_server解析出来后传给实现gen_server行为模式的同步回调接口,这就是From的前世今生,回调部分接口是在gen_server进程内部执行,通用部分接口是在客户端进程中执行。
客户端进程一直在侦听消息的到来,如果收到了同步调用的返回值,客户端进程是这样做的,首先执行demonitor解除与gen_server的监控关系,进而将结果返回,客户端进程从receive的阻塞状态跳出来,对外表现为同步调用返回;如果收到gen_server进程发来的{'DOWN',Mref,_,_,Reason}消息,客户端进程马上exit;如果timeout时间后依旧没有没有收到结果,便自动demonitor后,退出。
总结:1、erlang底层之所以让客户端进程单向monitor目标gen_server进程,就是想在同步调用过程,让客户端与gen_server进程有个“握手-分手”的过程,一旦gen_server进程挂了,客户端进程能够收到DOWN消息,进而客户端进程退出;
2、当进程A与进程B既有link关系,又有A到B的monitor时,一旦B进程挂了,exit退出信号会优先‘DOWN’发给进程A。
相关文章推荐
- ES transport client底层是netty实现,netty本质上是异步方式,但是netty自身可以使用sync或者await(future超时机制)来实现类似同步调用!因此,ES transport client可以同步调用也可以异步(不过底层的socket必然是异步实现)
- [转]浅析C++中虚函数的调用及对象的内部布局(利用汇编深刻理解C++虚函数底层实现机制)
- [转]浅析C++中虚函数的调用及对象的内部布局(利用汇编深刻理解C++虚函数底层实现机制)
- Binder系统_JAVA实现内部机制Server端
- 【嵌入式Linux学习七步曲之第五篇 Linux内核及驱动编程】Linux系统调用的实现机制分析
- SQLSERVER中,数据库同步的实现(转摘于:http://www.linux-cn.com/html/database/sqlserver/20070603/47479.html)
- [原创] Memcache分组和同步机制的实现
- Struts框架内部的值调用机制的研究
- 利用消息机制实现.NET AOP(面向方面编程)--利用ServerContextSink实现多截获
- 利用.net的内部机制在asp.net中实现身份验证
- 利用c#实现远程注入非托管WIN32程序,并利用嵌入汇编调用非托管WIN32程序中的内部过程
- 【转】Monitor Object 并发模式在 Java 同步机制中的实现
- AjaxPro实现机制探讨——Ajax是如何调用服务器端C#方法的?
- C#实现动态灵活调用业务方法的机制
- 利用.net的内部机制在asp.net中实现身份验证
- 利用.net的内部机制在asp.net中实现身份验证
- Castle AOP 系列(四):实现一个简单的基于上下文调用的权限校验机制
- 【AjaxPro实现机制浅析一】AjaxPro内部为我们做什么工作?
- 【AjaxPro实现机制浅析一】AjaxPro内部为我们做什么工作?
- AjaxPro实现机制探讨——Ajax是如何调用服务器端C#方法的?