網(wǎng)絡(luò)編程線程池問(wèn)題

kkshaq

[code]/* include serv08 */
#include "unpthread.h"
#include "pthread08.h"

static int nthreads;
pthread_mutex_t clifd_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t clifd_cond = PTHREAD_COND_INITIALIZER;

int
main(int argc, char **argv)
{
    int i, listenfd, connfd;
    void sig_int(int), thread_make(int);
    socklen_t addrlen, clilen;
    struct sockaddr *cliaddr;

    if (argc == 3)
        listenfd = Tcp_listen(NULL, argv[1], &addrlen);
    else if (argc == 4)
        listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
    else
        err_quit("usage: serv08 [ ] <#threads>");
    cliaddr = Malloc(addrlen);

    nthreads = atoi(argv[argc-1]);

    tptr = Calloc(nthreads, sizeof(Thread));

    iget = iput = 0;

        /* 4create all the threads */
    for (i = 0; i < nthreads; i++)
        thread_make(i); /* only main thread returns */

    Signal(SIGINT, sig_int);

    for ( ; ; ) {
        clilen = addrlen;
        connfd = Accept(listenfd, cliaddr, &clilen);

        Pthread_mutex_lock(&clifd_mutex);
        clifd[iput] = connfd;
        if (++iput == MAXNCLI)
            iput = 0;
        if (iput == iget)
            err_quit("iput = iget = %d", iput);
        Pthread_cond_signal(&clifd_cond);
        Pthread_mutex_unlock(&clifd_mutex);
    }
}






最近看unp27章中的服務(wù)器模型部分，27.12節(jié)是并發(fā)服務(wù)器程序，主線程統(tǒng)一accept
也就是主線程accept，worker線程工作那么模式。作者處理消費(fèi)者和生產(chǎn)者問(wèn)題的時(shí)候，使用了條件變量和互斥量達(dá)到同步。但是我覺(jué)得有些問(wèn)題
作者在考慮循環(huán)隊(duì)列的問(wèn)題上，是采用如此的策略，在生產(chǎn)者函數(shù)中，如果iput==iget，必然是數(shù)組緩沖區(qū)滿，作者直接采用的是、
if (iput == iget)
             err_quit("iput = iget = %d", iput);

也就是說(shuō)如果生產(chǎn)者的速度，大于消費(fèi)者的話，我們的主線程只能結(jié)束。。這個(gè)是不是有待商榷？？對(duì)應(yīng)的情況就是，如果多個(gè)客戶連接連續(xù)產(chǎn)生，工作子線程來(lái)不及處理的時(shí)候，我們的主線程就自己err_quit了。。
有沒(méi)有更好的辦法？（在只采用一個(gè)條件變量的條件下）

yulihua49

kkshaq 發(fā)表于 2015-06-28 15:26
[code]/* include serv08 */
#include "unpthread.h"
#include "pthread08.h"

根本不能這么玩。
純粹是個(gè)學(xué)生作業(yè)，沒(méi)有實(shí)用價(jià)值。

主線程接受連接，然后丟給epoll。線程池在epoll_wait。
接受的連接數(shù)可大大超過(guò)線程數(shù)。他們?cè)趀poll排隊(duì)。

kkshaq

yulihua49 發(fā)表于 2015-06-28 19:44
根本不能這么玩。
純粹是個(gè)學(xué)生作業(yè)，沒(méi)有實(shí)用價(jià)值。

線程池這個(gè)模型還是可以探討一下啊

消費(fèi)者和生產(chǎn)者之間同步的問(wèn)題。。為什么作者不使用真正的共享緩沖區(qū)同步呢。讓程序可以一直運(yùn)行下去。。不然像作者這樣，共享緩沖區(qū)滿了，主線程就得退出啊。
不知道是不是我錯(cuò)了，你覺(jué)得呢？？

hanzhenlll

文章只是告訴你 線程池實(shí)現(xiàn)的簡(jiǎn)單方式， 如果考慮那么全， 那么多代碼 怎么教學(xué)生啊，，要考慮篇幅。

yulihua49

kkshaq 發(fā)表于 2015-06-28 21:20
線程池這個(gè)模型還是可以探討一下啊

消費(fèi)者和生產(chǎn)者之間同步的問(wèn)題。。為什么作者不使用真正的共享緩沖 ...

一般是采用context做緩沖區(qū)，是每個(gè)連接獨(dú)享的。
采用epoll作為事件隊(duì)列。
凡是接入的連接，一律加到epoll隊(duì)列，隨后的IO事件都是由epoll處理�？梢杂卸鄠�(gè)線程。
epoll隊(duì)列完成了生產(chǎn)者-消費(fèi)者模型。
epoll之后的線程數(shù)，與核數(shù)有關(guān)，而與連接數(shù)無(wú)關(guān)。連接數(shù)與系統(tǒng)的fd數(shù)和應(yīng)用的context數(shù)有關(guān)。
連接數(shù)超過(guò)線程數(shù)也沒(méi)關(guān)系，在epoll里等就是了。只有它發(fā)生IO時(shí)才需要線程。
如果發(fā)生IO的連接數(shù)超過(guò)了線程數(shù)，也沒(méi)關(guān)系，等就是了。等到有線程完成了其他任務(wù)回來(lái)抓事件。