计划在C++建立仿Erlang式的分布式并行机制
梳理了下需求,大体如下:
进程(Process)。进程是Erlang中一个虚拟的运行单位。既不是操作系统的进程,也不是线程,而是比线程更加轻量的单位,更接近于协程。
命名进程(NamedProcess)。命名进程的好处是,你可以向一个不知道进程ID的进程发送消息。由于进程可能会宕掉(crash),进程ID可能会发生变化,所以在考虑了异常的环境下,命名进程降低了编码的难度(你不再需要考虑进程crash检测和重建连接的过程)。
进程邮箱(Mailbox)。每个进程都拥有一个自己的邮箱,其他进程发送消息到该邮箱,而进程在合适的时机从中取出消息并处理之。
定时器(Timer)。这个是属于最最基础的模块,用于多种用途,如超时检测等。
消息编码/解码(encode/decode)。将进程的请求(sync/async的函数调用)encode为网络消息流,或将网络消息流decode回进程的请求。
消息发送/接收(send/receive)。发送(send)指将消息(Message)发送到目标进程(Process)的进程邮箱(Mailbox)中。接收(receive)则从进程邮箱(Mailbox)取出消息(Message)。接收可以有选择性接收(selective receive),即按一定的匹配模式选择要接收的消息。
进程链接与监控(link/monitor)。当两个进程链接时,一个挂掉后会通知另一个进程。
速错(fail fast)。这关乎资源管理(Resource Management)与异常处理(Exception Handling)。Erlang的哲学是发生不可恢复的错误时就立即死掉。而进程的资源(如内存、打开的文件等等)需要被自动释放。
通用服务器(Server)。进程(Process)可能是一个普通的工作者(Worker),也可以是服务器(Server)。通用服务器架构实现了一套高可靠的服务器模型。
大致想象了下实现,已经基本有谱。
更多关于Erlang的详细信息,或者下载地址请点这里