#include "thread_pool.hxx"

// 线程函数
static void thread_test(thread_context_t *thread_ctx)
{
 char * pdata = (char *)getTaskArgFromContext(thread_ctx);

 if(pdata)
 {
 printf("Data %p\n", pdata);
 }
}

static class threadPool *m_pool;

int threadpool_demo(void)
{
 int thread_count = 20;
 int queue_size = 64;

 char data1[256];

 m_pool = new class threadPool(thread_count, queue_size);

 m_pool->addTask(thread_test, data1);

 //char data2[256];
 //m_pool->addTask(thread_test, data2);

 while(1);

 delete m_pool;

 return 0;
}

/*
int main(int argc, char * argv[])
{
 threadpool_demo();
 return 0;
}
*/