Function test_threads

internal/tests/core/test/test_notify.cpp:198–222

}

void test_threads(void)
{
    NotifyBus bus("thread", 1024, 256);

    int e0 = bus.CreateEvent("thread0");
    int e1 = bus.CreateEvent("thread1");
    int e2 = bus.CreateEvent("thread2");
    int e3 = bus.CreateEvent("thread3");
    int count = 10;

    std::thread t0(echo_thread, count, &bus, e0, e1);
    std::thread t1(echo_thread, count, &bus, e1, e2);
    std::thread t2(echo_thread, count, &bus, e2, e3);
    std::thread t3(echo_thread, count, &bus, e3, e0);

    // using furture and promise to get the  quit of threads

    while(true)
        bus.ProcessAllEvents();

    t0.join();
    t1.join();
    t2.join();
    t3.join();
}

int main(void)
{