if (size <= 0) { // 最小也需要有1个线程

size_ = 1;

} else {

size_ = size;

}

unsigned int msg_count = 0;

while (true) {

string msg = msg_queue_.pop();

if (msg.empty()) {

printf("no msg got, sleep for 0.1 sec\n");

usleep(100000); // 0.1 sec

continue;

}

if (msg == "__exit__") {

stringstream ss;

ss << "exit worker: " << std::this_thread::get_id() << ", processed: " << msg_count << "..";

printf("%s\n", ss.str().c_str());

return;

}

Handle(msg);

msg_count++;

if (msg_count % 1000 == 0) {

printf("every 1000 msg count\n");

}

}

for (int i=0; i < size_; i++) {

thread_pool_.push_back( thread(&WorkThreadPool::Worker, this) );

}

return 0;

for (int i=0; i < size_; i++) {

SendMessage("__exit__");

}

for (int i=0; i < size_; i++) {

thread_pool_[i].join();

}

return 0;