C语言并发编程的一种思维方式

1 C 语言并发编程的一种思维方式 现今 单台机器拥有多个独立的计算单元已经太常见了 这点在服务器的处理器上表现尤 为明显 据 AMD 的一张 2012 2013 服务器路线图显示 服务器处理器的核心数将在 2013 年达到 20 颗之多 合理的利用 CPU 资源已是一个不得不考虑的问题 不少 C 程序员依然使用着多线程模型 但是对多线程的掌控并不是一件容易的事情 开发中容易 出错 难以调试 有些开发者为了避免多线程带来的复杂度而弃用多线程 有些开发者则 另投其他语言阵营 例如 Erlang 其实我们还有其他的选择 Theron 就是其中之一 什么是 Theron Theron 是一个用于并发编程的 C 库 通过 Theron 我们可以避免多线程开发中各种 痛处 例如 共享内存 线程同步 Theron 通过 Actor 模型向我们展示了另一种思维 什么是 Actor 模型 Erlang 因为其优秀的并发特性而被大家所关注 而其并发特性的关键之一就是在于其采用 了 Actor 模型 与 Actor 模型相对应的模型则是我们在面向对象编程中使用的 Object 模型 Object 模型中宣扬 一切皆为 Object 对象 而 Actor 模型则认为一切皆为 Actor Actor 模型中 Actor 之间通过消息相互通信 这是其和 Object 模型的一个显着的 区别 换而言之 Actor 模型使用消息传递机制来代替了 Object 模型中的成员方法调用 这样做意义重大 因为相对于成员方法的调用来说 消息的发送是非阻塞的 它无需等待 被调用方法执行完成就可以返回 下图显示了此种区别 2 A a 调用了 objB b 此时 A a 必须等待 B b 的返回才能继续执行 在 Actor 模 型中 对应的做法是 Actor A 向 Actor B 发送消息并立即返回 这时候 Actor A 可以继 续执行下去 与此同时 Actor B 收到消息被唤醒并和 Actor A 并行执行下去 Theron 中的每个 Actor 都会绑定一个唯一的地址 通过 Actor 的地址就可以向其发 送消息了 每个 Actor 都有一个消息队列 从编码者的角度看来 每实例化一个 Actor 都创建了一个和 Actor 相关的 线程 非系统级的线程 每个 Actor 总是被单线程的执行 总结来说 Theron 的并发特性的关键就在于 每个 Actor 在属于自己的单个 线程 中执行 而多个 Actor 并发执行 Hello Theron include include include 定义一个消息类型 在 Theron 中 任何类型都可以作为一个消息类型 唯一的一个约束是消息类型的变量能够被拷贝的 消息按值发送 而非发送它们的地址 struct StringMessage char m string 64 用户定义的 Actor 总需要继承于 Theron Actor 每个 Actor 和应用程序的其他部分通信的唯一途径就是通过消息 class Actor public Theron Actor public inline Actor 3 注册消息的处理函数 RegisterHandler this private 消息处理函数的第一个参数指定了处理的消息的类型 inline void Handler const StringMessage if Send message from printf Failed to send message to address dn from AsInteger int main Framework 对象用于管理 Actors Theron Framework framework 通过 Framework 构建一个 Actor 实例并持有其引用 Actor 的引用类似于 Java C 等语言中的引用的概念 Theron ActorRef 采用引用计数的方式实现 类似于 boost shared ptr Theron ActorRef simpleActor framework CreateActor 创建一个 Receiver 用于接收 Actor 发送的消息 用于在非 Actor 代码中 例如 main 函数中 与 Actor 通信 Theron Receiver receiver 构建消息 StringMessage message strcpy message m string Hello Theron 4 通过 Actor 的地址 我们就可以向 Actor 发送消息了 if framework Send message receiver GetAddress simpleActor GetAddress printf Failed to send message n 等到 Actor 发送消息 避免被关闭主线程 receiver Wait return 0 这个范例比较简单 通过 Actor 输出了 Hello Theron 需要额外说明的一点是消息在 Actor 之间发送时会被拷贝 接收到消息的 Actor 只是引用到被发送消息的一份拷贝 这 么做的目的在于避免引入共享内存 同步等问题 Theron 的消息处理 前面谈到过 每 个 Actor 都工作在一个属于自己的 线程 上 我们通过一个例子来认识这一点 我们修改 上面例子中的 Actor Handler 成员方法 inline void Handler const StringMessage ifdef MSC VER Sleep 1000 else sleep 1 endif 此 Handler 会不断的打印 message 并且带上当前 Actor 的地址信息 在 main 函 数中 我们构建两个 Actor 实例并通过消息唤醒它们 再观察输出结果 Hello Theron 1 Hello Theron 2 5 Hello Theron 2 Hello Theron 1 Hello Theron 2 Hello Theron 1 Hello Theron 2 Hello Theron 1 这和我们预期的一样 两个 Actor 实例在不同的线程下工作 实际上 Framework 创建的时候会创建系统级的线程 默认情况下会创建两个 可以通过 Theron Framework 构造函数的参数决定创建线程的数量 它们构成一个线程池 我们 可以根据实际的 CPU 核心数来决定创建线程的数量 以确保 CPU 被充分利用 线程池 的线程是以何种方式进行调度的 如下图 接收到消息的 Actor 会被放置于一个线程安全的 Work 队列中 此队列中的 Actor 会被唤醒的工作线程取出 并进行消息的处理 这个过程中有两个需要注意的地方 对于某个 Actor 我们可以为某个消息类型注册多个消息处理函数 那么此消息类型对 应的多个消息处理函数会按照注册的顺序被串行执行下去 6 线程按顺序处理 Actor 收到的消息 一个消息未处理完成不会处理消息队列中的下一 个消息 我们可以想象 如果存在三个 Actor 其中两个 Actor 的消息处理函数中存在死循 环 例如上例中的 while true 那么它们一旦执行就会霸占两条线程 若线程池中没有多 余线程 那么另一个 Actor 将被 饿死 永远得不到执行 我们可以在设计上避免这种 Actor 的出现 当然也可以适当的调整线程池的大小来解决此问题 Theron 中 线程池中 线程的数量是可以动态控制的 线程利用率也可以测