Linux网络服务器epoll模型的socket通讯的实现(一)

  准备写一个网络游戏的服务器的通讯模块，参考网上看到的一些代码，在linux下面实现一个多线程的epoll模型的socket通讯的代码,以下是第一部分多线程的切换代码:  1 #include <stdio.h>  2 #include <sys/types.h>  3 #include <sys/epoll.h>  4 #include <sys/socket.h>  5 #include <signal.h>  6 #include <fcntl.h>  7 #include <map>  8 #include <errno.h>  9 #include <pthread.h> 10 #include <stdlib.h> 11 #include <unistd.h> 12 using namespace std; 13  14 struct conninfo{ 15     int rfd; 16     int wfd; 17     //map<struct ipport, struct perrinfo> peer; 18 }; 19  20 bool g_bRun; 21  22 struct conninfo g_ConnInfo; 23  24 void setnonblocking(int sock) 25 { 26     int opts; 27     opts = fcntl(sock, F_GETFL); 28     if(opts < 0) 29     { 30         PRintf("fcntl(sock, GETFL)"); 31         exit(1); 32     } 33     opts = opts | O_NONBLOCK; 34     if(fcntl(sock, F_SETFL, opts) < 0) 35     { 36         printf("fcntl(sock, SETFL, opts)"); 37         exit(1); 38     } 39     return ; 40 } 41  42 static void sig_pro(int signum) 43 { 44     printf("sig_pro recv signal: %d/n", signum); 45     if(signum == SIGQUIT) 46     { 47         g_bRun = false; 48     } 49 } 50  51 void* AcceptThread(void* arg) 52 { 53     printf("accpet thread/n"); 54     return NULL; 55 } 56  57 void* ReadThread(void* arg) 58 { 59     printf("read thread/n"); 60     return NULL; 61 } 62  63 int main() 64 { 65     int ret; 66     int fd[2];  //pipe 67     pthread_t iAcceptThreadId; 68     pthread_t iReadThreadId; 69  70     struct sigaction sa; 71     sa.sa_flags = SA_RESTART; 72     sa.sa_handler = sig_pro; 73     sigaction(SIGINT, &sa, NULL); 74     sigaction(SIGUSR1, &sa, NULL); 75     sigaction(SIGUSR2, &sa, NULL); 76      77  78     g_bRun = true; 79     ret = pipe(fd); 80     if(ret < 0) 81     { 82         printf("main, pipe fall, %d %s/n", ret, errno); 83         g_bRun = false; 84         return 0; 85     } 86      87     g_ConnInfo.rfd = fd[0]; 88     g_ConnInfo.wfd = fd[1]; 89  90     setnonblocking(g_ConnInfo.rfd); 91      92     pthread_attr_t attr; 93     pthread_attr_init(&attr); 94     pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM); 95  96     ret = pthread_create(&iAcceptThreadId, &attr, AcceptThread, NULL); 97     if(ret != 0) 98     { 99         printf("main, create accept thread fail: %s/n", errno);    100         g_bRun = false;101         close(g_ConnInfo.rfd); //关闭管道102         close(g_ConnInfo.wfd);103         return 0;104     }105     106     ret = pthread_create(&iReadThreadId, &attr, ReadThread, NULL);107     if(ret != 0)108     {109         printf("main, create read thread fail: %s/n", errno);110         g_bRun = false;111         pthread_join(iAcceptThreadId, NULL);112         close(g_ConnInfo.rfd);　　　　113         close(g_ConnInfo.wfd);114         115         return 0;116     }117     118     while(g_bRun)119     {120         sleep(1);121     }122 123     pthread_join(iAcceptThreadId, NULL);  //收回线程的资源，销毁线程124     pthread_join(iReadThreadId, NULL);125     close(g_ConnInfo.rfd);126     close(g_ConnInfo.wfd);127 128     return 0;    129 }