/*** 
 * @Description: 
 * @Author: LeoTao
 * @Date: 2023-10-12 03:13:04
 * @LastEditTime: 2023-10-12 04:27:10
 */
#include "EventLoopThread.h"
#include "EventLoop.h"
EventLoopThread::EventLoopThread(const ThreadInitCallback& cb,
                const std::string& name)
                :loop_(nullptr),
                exiting_(false),
                thread_(std::bind(&EventLoopThread::threadFunc,this), name),
                mutex_(),
                cond_(),
                callback_(cb){}

EventLoopThread::~EventLoopThread(){
    exiting_ = true;
    if(loop_ != nullptr){
        loop_->quit();
        thread_.join();
    }
}

EventLoop* EventLoopThread::startLoop(){
    //先启动底层的线程
    thread_.start();

    EventLoop *loop = nullptr;
    {
        std::unique_lock<std::mutex> lock(mutex_);
        while(loop_ == nullptr){
            cond_.wait(lock);
        }
        loop = loop_;
    }
    return loop;
}

//下面这个方法是在单独的线程中执行
void EventLoopThread::threadFunc(){
    EventLoop loop; //创建一个独立的eventloop， 和上面的线程是一一对应的， one loop per thread
    if(callback_){
        callback_(&loop);
    }

    {
        std::unique_lock<std::mutex> lock(mutex_);
        loop_ = &loop;//绑定
        cond_.notify_one();
    }
    loop.loop(); //eventloop loop =》 poller.poll
    std::unique_lock<std::mutex> lock(mutex_);
    loop_ = nullptr;
}