#include "ThreadPool.h"

#include <stdio.h>

#include <assert.h>

#include <stdlib.h>

namespace zl

{

ThreadPool::ThreadPool(int threadNum)

}

ThreadPool::~ThreadPool()

{

stop();

for(std::deque<Task*>::iterator it = taskQueue_.begin(); it != taskQueue_.end(); ++it)

{

delete *it;

}

taskQueue_.clear();

}

int ThreadPool::createThreads()

}

size_t ThreadPool::addTask(Task *task)

}

void ThreadPool::stop()

}

int ThreadPool::size()

}

Task* ThreadPool::take()

{

Task* task = NULL;

while (!task)

{

pthread_mutex_lock(&mutex_);

while (taskQueue_.empty() && isRunning_)

{

pthread_cond_wait(&condition_, &mutex_);

}

if (!isRunning_)

{

pthread_mutex_unlock(&mutex_);

break;

}

else if (taskQueue_.empty())

{

pthread_mutex_unlock(&mutex_);

continue;

}

assert(!taskQueue_.empty());

task = taskQueue_.front();

taskQueue_.pop_front();

pthread_mutex_unlock(&mutex_);

}

return task;

}

void* ThreadPool::threadFunc(void* arg)

{

pthread_t tid = pthread_self();

ThreadPool* pool = static_cast<ThreadPool*>(arg);

while (pool->isRunning_)

{

Task* task = pool->take();

if (!task)

{

printf("thread %lu will exit\n", tid);

break;

}

assert(task);

task->run();

}

return 0;

}

}