[prog] Erlang-style мониторы и супервизоры -- это хорошо, но не ими одними :)

В процессе подготовки презентации об обработки исключений в SObjectizer написал небольшой пример, показывающий, как кооперация перерегистрирует сама себя, если до этого ее грохнули из-за выскочившего наружу исключения.

#include <iostream> #include <so_5/all.hpp> using namespace so_5; using namespace so_5::rt; using namespace std; void start_coop( environment_t & env ) {    env.introduce_coop( [&]( agent_coop_t & coop ) {       struct raise_exception : public signal_t {};       // The single agent of the coop.       // Will throw an exception after one seconds from registration.       auto agent = coop.define_agent();       agent.on_start( [agent, &env] {             send_delayed< raise_exception >(                   env, agent.direct_mbox(), chrono::seconds(1) );          } )          .event< raise_exception >( agent.direct_mbox(), [] {             throw runtime_error( "Just a test exception" );          } );       // Tell to SObjectizer to deregister the coop on exception.       coop.set_exception_reaction( deregister_coop_on_exception );       // Add notificator which will initiate reregistration of the coop.       coop.add_dereg_notificator(          []( environment_t & env,             const string & coop_name,             const coop_dereg_reason_t & why )          {             cout << "Deregistered: " << coop_name << ", reason: " << why.reason() << endl;             if( dereg_reason::unhandled_exception == why.reason() )                start_coop( env );          } );    } ); } int main() {    so_5::launch( []( environment_t & env ) {          // Register coop the first time.          start_coop( env );          // Take some time to the example to work.          this_thread::sleep_for( chrono::seconds( 5 ) );          env.stop();       } ); }