: baseLoop_(baseLoop),

started_(false),

numThreads_(numThreads),

next_(0)

{

if (numThreads_ <= 0)

{

LOG << "numThreads_ <= 0";

abort();

}

{

baseLoop_->assertInLoopThread();

started_ = true;

for (int i = 0; i < numThreads_; ++i)

{

std::shared_ptr<EventLoopThread> t(new EventLoopThread());

threads_.push_back(t);

loops_.push_back(t->startLoop());

}