sobjectizer

项目介绍：SObjectizer

什么是SObjectizer？

SObjectizer是一个跨平台、开源的C++“actor框架”之一。它不仅支持Actor模型，还支持发布-订阅模型和类似CSP（通信顺序进程）的通道。SObjectizer的目标是大幅简化C++并发和多线程应用的开发。

在SObjectizer中，开发者可以通过创建一组代理对象来构建并发应用，这些对象通过异步消息进行交互。框架负责消息的分发，并为消息处理提供工作上下文。同时，开发者可以通过提供多种现成的分发器来优化这些功能。

SObjectizer的独特之处

成熟度：SObjectizer基于1995-2000年提出的理念，自2002年以来一直在开发，并自2010年起不断演进。
稳定性：从一开始，SObjectizer就被用于业务关键应用，其中一些至今仍在使用。在对SObjectizer进行变更时，我们非常谨慎。
跨平台：SObjectizer可以运行在Windows、Linux、FreeBSD、macOS和Android平台上。
易用性：SObjectizer提供了易于理解和使用的API，且在项目的发行版中包含了大量示例，以及在项目Wiki中提供了丰富的信息。
免费：SObjectizer在BSD-3-CLAUSE许可证下分发，可以免费用于专有商用软件的开发。

与TBB、taskflow或HPX的区别

SObjectizer经常与Intel Threading Building Blocks、taskflow和HPX等工具进行比较。然而，这种比较并不合适。那些工具主要用于并行计算，旨在通过利用多个CPU核心来减少计算时间，而SObjectizer则专注于简化同时处理多个不同任务的过程，不一定需要多个CPU核心。

在SObjectizer上可以实现的应用实例包括多线程代理服务器、自动控制系统、MQ代理、数据库服务器等。

代码示例

HelloWorld 示例

一个通过使用SObjectizer的代理来实现的经典“Hello, World”程序：

#include <so_5/all.hpp>

class hello_actor final : public so_5::agent_t {
public:
   using so_5::agent_t::agent_t;

   void so_evt_start() override {
      std::cout << "Hello, World!" << std::endl;
      so_deregister_agent_coop_normally();
   }
};

int main() {
   so_5::launch([](so_5::environment_t & env) {
       env.register_agent_as_coop(env.make_agent<hello_actor>());
   });
   return 0;
}

Ping-Pong 示例

通过两个代理之间的消息交换实现的“Ping-Pong”示例：

#include <so_5/all.hpp>

struct ping { int counter_; };
struct pong { int counter_; };

class pinger final : public so_5::agent_t {
   so_5::mbox_t ponger_;
   void on_pong(mhood_t<pong> cmd) {
      if(cmd->counter_ > 0)
         so_5::send<ping>(ponger_, cmd->counter_ - 1);
      else
         so_deregister_agent_coop_normally();
   }
public:
   pinger(context_t ctx) : so_5::agent_t{std::move(ctx)} {}
   void set_ponger(const so_5::mbox_t mbox) { ponger_ = mbox; }
   void so_define_agent() override { so_subscribe_self().event(&pinger::on_pong); }
   void so_evt_start() override { so_5::send<ping>(ponger_, 1000); }
};

class ponger final : public so_5::agent_t {
   const so_5::mbox_t pinger_;
   int pings_received_{};
public:
   ponger(context_t ctx, so_5::mbox_t pinger)
      : so_5::agent_t{std::move(ctx)}, pinger_{std::move(pinger)} {}
   void so_define_agent() override {
      so_subscribe_self().event([this](mhood_t<ping> cmd) {
         ++pings_received_;
         so_5::send<pong>(pinger_, cmd->counter_);
      });
   }
   void so_evt_finish() override {
      std::cout << "pings received: " << pings_received_ << std::endl;
   }
};

int main() {
   so_5::launch([](so_5::environment_t & env) {
         env.introduce_coop([](so_5::coop_t & coop) {
               auto pinger_actor = coop.make_agent<pinger>();
               auto ponger_actor = coop.make_agent<ponger>(pinger_actor->so_direct_mbox());
               pinger_actor->set_ponger(ponger_actor->so_direct_mbox());
         });
   });
   return 0;
}