Linux下的程序池 1

基於linux的程序池的實現，併發程序池有多種實現模式，在這裡統一進行分析。首先給出客戶端的測試**：

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
const
int clientnum =10;
// 建立使用者個數
const
int nloop =
100;
// 每個使用者動態建立連線個數
static
int cnt =0;
void sig_handler (
int sig)
pid_t pid;
while
((pid = waitpid (-1
,null
, wnohang)
)>0)
if(cnt >= clientnum)
}int main (
int argc,
char
* ar**)
int port = atoi (ar**[2]
);if(port <
1024
|| port >
65535
)struct sockaddr_in serv;
bzero (
&serv,
sizeof
(serv));
if(inet_pton (af_inet, ar**[1]
,&serv.sin_addr)==-
1)serv.sin_family = af_inet;
serv.sin_port = htons (port)
;struct sigaction sa;
bzero (
&sa,
sizeof
(sa));
sa.sa_handler = sig_handler;
sa.sa_flags = sa_restart;
if(sigaction (sigchld,
&sa,
null
)<0)
for(
int i =
0; i < clientnum;
++i)
if(connect (fd,
(struct sockaddr*
)&serv,
sizeof
(serv)
)<0)
const
char
* buf =
"hello world !\n"
;for
(int j =
0; j < nloop;
++j)
close (fd)
;            printf (
"client %d end...\n"
, i)
;            exit (0)
;}}while
(true
)    exit (0)
;}

這裡介紹的是使用不帶鎖的accept結構的程序池。原理是：如果有多個accept函式等待監聽核心中同乙個fd，那麼沒有資料時都阻塞。如果有資料，那麼所有的都會被喚醒，但是只能有乙個程序獲取fd，其餘的喚醒後接著休眠。這種結構簡單，但是出現執行緒池「驚群」現象，這裡的喚醒和休眠會浪費大量的時間，併發度高的時候，更是如此。但是對於少量併發的情況，還是比較合適的，給出**實現：

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
const
int max_process_number =15;
const
int max_buffer_size =
1024
;bool stop_server =
false
;pid_t* pids =
nullptr
;int processnum =0;
void sig_int (
int signo)
;// 終止整個執行緒池
void process (
int fd)
;// 子程序處理連線
pid_t child_make (
int fd)
;// 產生新的子程序
void child_main (
int fd)
;// 子程序的主要操作
int main (
int argc,
char
* ar**)
int port = atoi (ar**[1]
);if(port <
1024
|| port >
65535
)    processnum = atoi (ar**[2]
);if(processnum <
0|| processnum > max_process_number)
struct sockaddr_in serv;
bzero (
&serv,
sizeof
(serv));
serv.sin_family = af_inet;
serv.sin_port = htons (port)
;    serv.sin_addr.s_addr = htonl (inaddr_any)
;int listenfd = socket (af_inet, sock_stream,0)
;if(listenfd <0)
if(bind (listenfd,
(struct sockaddr*
)&serv,
sizeof
(serv)
)<0)
if(listen (listenfd,32)
<0)
struct sigaction sa;
// 註冊終止訊號
bzero (
&sa,
sizeof
(sa));
sa.sa_handler = sig_int;
sa.sa_flags = sa_restart;
if(sigaction (sigterm,
&sa,
null
)<0)
pids =
new pid_t[processnum]
;for
(int i =
0; i < processnum;
++i)
while
(!stop_server)
exit (0)
;}void sig_int (
int signo)
for(
int i =
0; i < processnum;
++i)
if(pids !=
nullptr
)    stop_server =
true;}
pid_t child_make (
int fd)
child_main (fd);}
void child_main (
int fd)
puts (
"accept data");
process (connfd)
;        close (fd);}
}void process (
int fd)
printf (
"%s"
, buf);}
}

Linux下的程序池 1

Linux 程序池實現

程序，執行緒與執行緒池（1）

linux下的程序

Linux下的程序池 1

Linux 程序池實現

程序，執行緒與執行緒池（1）

linux下的程序

相關推薦