Erlang进程模型在C++中的实践.pptVIP

51.com系统架构组 * 1. main process 发送消息给 child process; child process的Mailbox中收到消息; main process 交出执行权给scheduler; scheduler将执行权交给之前阻塞在receive() 上的child process 2. child process从自己的mailbox中获得消息， 并回复之 * 1. main process 发送消息给 child process; child process的Mailbox中收到消息; main process 交出执行权给scheduler; scheduler将执行权交给之前阻塞在receive() 上的child process 2. child process从自己的mailbox中获得消息， 并回复之 * 1. 上层开发者调用ac_actor库中的socket_read()函数 ? 2. socket_read() 在scheduler的事件循环中注册该socket的读事件，ProcessA主动交出代码的执行权，scheduler开始执行 ? 3. scheduler此时没有可处理的事件，进入事件循环等待状态 (4). 此时可能有ProcessB注册的事件到达，scheduler将执行权交给该进程 (5). ProcessB执行剩余代码，直到进程结束或主动交出执行权，scheduler获取执行权 ? 6. socket的read事件到达，scheduler将执行权交给ProcessA。 ProcessA执行后续代码 7. socket_read()调用完毕，返回用户代码。 注： (4)，(5) 两步可能没有也可能有很多 * 1. 上层开发者调用ac_actor库中的file_read()函数 ? 2. file_read() 调用aio_read()，并主动交出执行权 ? 3. scheduler此时没有可处理的事件，进入事件循环等待状态 (4). 此时可能有ProcessB注册的事件到达，scheduler将执行权交给该进程 (5). ProcessB执行剩余代码，直到进程结束或主动交出执行权，scheduler获取执行权 ? 6.aio_read()执行完毕，通知scheduler，scheduler处理该事件 7.scheduler将执行权交给ProcessA ? 8.? file_read()调用完毕，返回 注： (4)，(5) 两步可能没有也可能有很多 * 1. 上层开发者调用ac_actor库中的file_read()函数 ? 2. file_read() 调用aio_read()，并主动交出执行权 ? 3. scheduler此时没有可处理的事件，进入事件循环等待状态 (4). 此时可能有ProcessB注册的事件到达，scheduler将执行权交给该进程 (5). ProcessB执行剩余代码，直到进程结束或主动交出执行权，scheduler获取执行权 ? 6.aio_read()执行完毕，通知scheduler，scheduler处理该事件 7.scheduler将执行权交给ProcessA ? 8.? file_read()调用完毕，返回 注： (4)，(5) 两步可能没有也可能有很多 Erlang进程模型在C++中的实践 ac_actor实现浅析 2009-11 51.com系统架构组 实际案例 ? 2009-11 51.com系统架构组 设计需求 1. 开发一个取用户基础信息及好友列表的访问服务器，客户端通过访问此服务器便能获取到某个用户的信息及好友列表。 ? 2. 用户基础信息和好友信息存放在其他机器上，访问服务器只能通过不同的接口获取这两类信息。 ? 3. 访问服务器需要记录每个客户端的ip地址。 4. 请求的平均处理时间尽可能的短 2009-11 51.com系统架构组 访问请求流程图 2009-11 51.com系统架构组 找出流程中可并行的部分 2009-11 51.com系统架构组 基于Callback+状态机实现的优缺点 优点 ?常规方法，原理容易理解 ? 缺点 代码编写较复杂，程序员大部分的精力都放在了如何更好的构造和处理状态机上 后期维护，状态扩展较复杂 2009-11 51.com系统架构组 基于ac_actor实现的伪码 void process_request() { ??? Future getUserInfo(get_user_info);??? // launch step 2??? Future getFriendList(get_friend_list); // launch step 3