CAF（C++ actor framework）使用随笔（各种send通信用法）（三）

#include <iostream>
#include "caf/all.hpp"
#include "caf/io/all.hpp"
#include <string>
#include <thread>
#include <chrono>
#include <unistd.h>
using namespace std;
using namespace caf;


behavior fun(event_based_actor* self){
    return {
        [self](const string& str, const actor &buddy)->string {
            aout(self)<<str<<endl;
            //self->delayed_send(buddy,std::chrono::milliseconds(10),"I‘m lated");        
            //std::this_thread::sleep_for(std::chrono::seconds(1));
            //usleep(10000);
            while(1);
            return "log";
            self->quit();
         }
    };
}

void fun1(event_based_actor* self, const actor &buddy){
    self->sync_send(buddy,"hi!",self).then(
         [=](const string& str) {
             aout(self)<<str<<endl;
         },
         after(std::chrono::milliseconds(1))>>[&](){
            aout(self)<<"timeout!"<<endl;
         }
    );
    aout(self)<<"i‘m not waiting for you!"<<endl;
}

int main(){
    auto actor1 = spawn(fun);
    auto actor2 = spawn(fun1,actor1);
    caf::await_all_actors_done();
    shutdown();
    return 0;
}

#include <iostream>
#include "caf/all.hpp"
#include "caf/io/all.hpp"
#include <string>
#include <chrono>
using namespace std;
using namespace caf;


behavior fun(event_based_actor* self){
    return {
        [self](const string& str)->string {
            aout(self)<<str<<endl;
            return "I got it.";
            //self->quit();
         }
    };
}

void fun1(blocking_actor* self, actor buddy){
    self->sync_send(buddy,"hi!").await(
         [=](const string& str) {
             aout(self)<<str<<endl;
         },
         after(std::chrono::milliseconds(1))>>[&](){
            aout(self)<<"timeout!"<<endl;
         }
    );
    aout(self)<<"i‘m not waiting for you!"<<endl;
}

int main(){
    auto actor1 = spawn(fun);
    auto actor2 = spawn<blocking_api>(fun1,actor1);
    caf::await_all_actors_done();
    shutdown();
    return 0;
}