#include "Task.h"
#include "threadPool.h"
#include "threadPool.cpp" //由于模æ¿ç±»çš„声明和实现是分开的，所以需è¦åŒ…å«æºæ–‡ä»¶ï¼Œå¦åˆ™å°±ä¼šæŠ¥é”™â€œæœªå®šä¹‰çš„引用â€
#include "TaskQueue.h"
#include
#include
#include
#include
#include
#include
using namespace std;
//工作函数
void taskFunction(void* arg)
{
//需è¦å¯¹ä¼ 入的地å€è¿›è¡Œç±»åž‹è½¬æ¢ï¼Œç„¶åŽå†è§£å¼•ç”¨ï¼Œå¾—到该地å€ä¿å˜çš„æ•°æ®
int num=*(int*)arg;
// printf("thread %ld is working, number = %d \n",pthread_self(),num);
cout<<"thread "< pool(minThread,maxThread); //当线程执行完毕会自动æžæž„，所以这里就ä¸å†éœ€è¦ä¸»åŠ¨è°ƒç”¨æžæž„函数了
//æ·»åŠ 100个任务
//ä½¿ç”¨å † 内å˜
//int * num=(int *)malloc(sizeof(int));
for(int i=0;i(taskFunction,num));
}
//ä¿è¯å·¥ä½œçº¿ç¨‹å·²ç»å¤„ç†å®Œæ¯•
sleep(20);
return 0;
}