UNIXネットワークプログラミング-クライアント/サーバプログラム設計モデル(六)
1326 ワード
TCP同時サーバープログラム、顧客ごとに1スレッド
前述したように、各クライアントのプロセスのサーバ、または各クライアントのフィールドforkのサブプロセス、または予め一定数のサブプロセスを派生させる.サーバホストがスレッドをサポートしている場合は、サブプロセスの代わりにスレッドを変更できます.
プライマリ・スレッド・ループ23-28プライマリ・スレッドの大部分はaccept呼び出しにブロックされ、クライアント接続が返されるたびにpthread_が呼び出される.createは新しいスレッドを作成します.新しいスレッドが実行する関数の場合doit、そのパラメータは返される接続されたソケットです.
各スレッドの関数31-40 doit関数は、プライマリスレッドがそれを待つ必要がなく、web_を呼び出すように、まず自分を離れます.Client関数です.この関数が戻ったら、接続されたソケットを閉じます.
前述したように、各クライアントのプロセスのサーバ、または各クライアントのフィールドforkのサブプロセス、または予め一定数のサブプロセスを派生させる.サーバホストがスレッドをサポートしている場合は、サブプロセスの代わりにスレッドを変更できます.
#include "unpthread.h"
int
main(int argc, char **argv)
{
int listenfd, connfd;
void sig_int(int);
void *doit(void *);
pthread_t tid;
socklen_t clilen, addrlen;
struct sockaddr *cliaddr;
if (argc == 2)
listenfd = Tcp_listen(NULL, argv[1], &addrlen);
else if (argc == 3)
listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
else
err_quit("usage: serv06 [ <host> ] <port#>");
cliaddr = Malloc(addrlen);
Signal(SIGINT, sig_int);
for ( ; ; ) {
clilen = addrlen;
connfd = Accept(listenfd, cliaddr, &clilen);
Pthread_create(&tid, NULL, &doit, (void *) connfd);
}
}
void *
doit(void *arg)
{
void web_child(int);
Pthread_detach(pthread_self());
web_child((int) arg);
Close((int) arg);
return(NULL);
}
void
sig_int(int signo)
{
void pr_cpu_time(void);
pr_cpu_time();
exit(0);
}
プライマリ・スレッド・ループ23-28プライマリ・スレッドの大部分はaccept呼び出しにブロックされ、クライアント接続が返されるたびにpthread_が呼び出される.createは新しいスレッドを作成します.新しいスレッドが実行する関数の場合doit、そのパラメータは返される接続されたソケットです.
各スレッドの関数31-40 doit関数は、プライマリスレッドがそれを待つ必要がなく、web_を呼び出すように、まず自分を離れます.Client関数です.この関数が戻ったら、接続されたソケットを閉じます.