Linux C++ 服务器之线程池 C++11

#include <iostream> #include "thread_pool.h" #include "myTask.h" #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <arpa/inet.h> int Socket(int ); int main(int argc,char** argv) { int port=8888; if(argc==2){ port=atoi(argv[1]); } int s=Socket(port); int n=20; thread_pool<task> pool(n); pool.start(); cout<<"Start server------\n"; while(1){ struct sockaddr_in addr; socklen_t len=sizeof(addr); int c=accept(s,(struct sockaddr*)&addr,&len); task* t=new task(c); pool.append_task(t); } return 0; } int Socket(int port){ int s=socket(AF_INET,SOCK_STREAM,0); struct sockaddr_in addr; bzero(&addr,sizeof(addr)); addr.sin_family=AF_INET; addr.sin_port=htons(port); addr.sin_addr.s_addr=htonl(INADDR_ANY); bind(s,(struct sockaddr*)&addr,sizeof(addr)); listen(s,100); return s; }