Function TEST

thread/test/test.cpp:174–201

}

TEST(Sleep, queue)  //Sleep_queue_Test::TestBody
{
    const int heap_size  = 1000000;
    const int rand_limit = 100000000;

    auto seed = /* time(0); */10007;
    srand(seed);
    SleepQueue sleepq;
    sleepq.q.reserve(heap_size);
    vector<photon::thread*> items;

    LOG_INFO("ITEMS WITH SAME VALUE.");
    for (int i = 0; i < heap_size; i++){
        auto th = new photon::thread();
        th->ts_wakeup = 1000;/* rand() % 100000000 */;
        items.emplace_back(th);
    }
    sleepq_perf(sleepq, items);

    LOG_INFO("ITEMS WITH RANDOM VALUE.");
    for (auto th: items)
        th->ts_wakeup = rand() % rand_limit;
    sleepq_perf(sleepq, items);

    LOG_INFO("sleepq test done.");
    for (auto th : items)
        delete th;
}

thread_local photon::condition_variable aConditionVariable;
thread_local photon::mutex aMutex;