/*
 * EventLoopThreadPool_test.cpp
 *
 * @build: make evpp
 *
 */

#include "hv.h"

#include "EventLoopThreadPool.h"

using namespace hv;

static void onTimer(TimerID timerID, int n) {
 printf("tid=%ld timerID=%lu time=%lus n=%d\n", hv_gettid(), (unsigned long)timerID, (unsigned long)time(NULL), n);
}

int main(int argc, char* argv[]) {
 HV_MEMCHECK;
 hlog_set_level(LOG_LEVEL_DEBUG);

 printf("main tid=%ld\n", hv_gettid());

 EventLoopThreadPool loop_threads(4);
 loop_threads.start(true);

 int thread_num = loop_threads.threadNum();
 for (int i = 0; i < thread_num; ++i) {
 EventLoopPtr loop = loop_threads.nextLoop();
 printf("worker[%d] tid=%ld\n", i, loop->tid());

 loop->runInLoop([loop](){
 // runEvery 1s
 loop->setInterval(1000, std::bind(onTimer, std::placeholders::_1, 100));
 });

 loop->queueInLoop([](){
 printf("queueInLoop tid=%ld\n", hv_gettid());
 });

 loop->runInLoop([](){
 printf("runInLoop tid=%ld\n", hv_gettid());
 });
 }

 // runAfter 10s
 loop_threads.loop()->setTimeout(10000, [&loop_threads](TimerID timerID){
 loop_threads.stop(false);
 });

 // wait loop_threads exit
 loop_threads.join();

 return 0;
}