:mWorkerThreadNum(threadNum),

mBufferQueueSize(bufferQueueSize),

mBufferQueuePtr(new BufferQueue(bufferQueueSize)) {

assert(threadNum);

assert(bufferQueueSize);

assert(mBufferQueuePtr);

// init mWorkerThreadVec

mWorkerThreadVec.resize(threadNum);

for (size_t i = 0; i < threadNum; i++) {

mWorkerThreadVec[i].reset(new WorkerThread(mBufferQueuePtr));

}

for(size_t i = 0; i < mWorkerThreadNum; i++) {

mWorkerThreadVec[i]->Start();

}