Function TestMessageBus_3

internal/tests/core/test/test_message_bus.cpp:254–289

}

void TestMessageBus_3()
{
    Mama ma(true);
    Child tom(true, string("Tom"), string("Delicious!"));
    Child rose(true, string("Rose"), string("Just so so!"));
    Child jean(true, string("Jean"), string("Terrible!"));
    cout << "0==================================================" << endl;
    ma.Cooking();
    cout << "1==================================================" << endl;
    while(!g_amsgbus.MessageEmpty())
    {
        g_amsgbus.ProcessOneMessage();
    }
    cout << "2==================================================" << endl;
    ma.Cooking();
    cout << "3==================================================" << endl;
    g_amsgbus.ProcessAllMessage();
    cout << "4==================================================" << endl;
    {
        Timer tm;
#if 1
        int64_t i = 0;
        while(i++ < 100000L)
        {
            ma.Cooking();
            g_amsgbus.ProcessAllMessage();
        }
#else
        std::shared_future<void> task = std::async(std::launch::async /*deferred*/,    // std::launch::async
                                                   test_async_1, &ma /*, &tom, &rose, &jean*/
        );
        task.get();
#endif
        cerr << 100000L * 1000 / tm.elapsed_ms() << "times/s\n";
    }
}

int main()
{