[問題] socket接受multi client的問題

[viewstock (股市觀察者)]

if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){
                perror("socket");
                exit(1);
        }


        addr.sin_family = AF_INET;
        addr.sin_port = htons(5000);
        addr.sin_addr.s_addr = htonl(INADDR_ANY);
        bzero( &(addr.sin_zero), 8 );


        if ( bind(sockfd, (struct sockaddr*)&addr, sizeof(struct sockaddr))
        == -1 ){
                perror("bind");
                exit(1);
        }

        while(1){

                if ( listen(sockfd, 10) == -1 ){
                        perror("listen");
                        exit(1);
                }

                if ( (new_fd[num] = accept(sockfd, (struct sockaddr*)
                &their_addr, &sin_size)) == -1 ){
                        perror("accept");
                        exit(1);
                }


                res = pthread_create( &(accept_thread[times]), NULL,
                thread_function, (void *)p_num );
                if (res != 0){
                        perror("Thread create failed!n");
                        exit(EXIT_FAILURE);
                }
                num++;
                times++;
        }
        close(sockfd);
        return 0;
}

以上是server片段程式
我想實作一個就是可以接受多個client的socket
以上的code可以做到接收多個client但無法同時執行pthread_create
就是說當我第一個client連線到server時,正執行pthread的thread_function時
當有其他client連入,必須等到pthread結束..等下個accept後才能執行
但我想做到的是
當第一個client連線執行時,這時有另一個client連入後可以馬上接受accept並執行
pthread的thread_function
不知道要如何修改才能達到?

--
※ 發信站: 批踢踢實業坊(ptt.cc), 來自: 175.98.141.254
※ 文章網址: https://www.ptt.cc/bbs/C_and_CPP/M.1481854942.A.B04.html
→ Schottky: listen 只需要 listen 一次，不用一直 loop
→ Schottky: 單純回答你的問題，就多開幾個thread/process來接收連線
→ Schottky: 建議在 accept() 加上 lock 一次只讓一個 thread 接收
→ Schottky: 不過如果你要的是效能(提高每秒連線數)，
→ Schottky: 那又是另一個問題了...
→ Schottky: multi-process 一起 listen 同一個 socket 的方法可以參
→ Schottky: 考 Richard Stevens 的 Unix Network Programming
→ Schottky: 裡面有完整的 sample code
推 a1u1usul3: 不大懂樓主的意思，create應該立刻就結束，就進下一個
→ a1u1usul3: 迴圈去接受新的client了不是嗎？
→ a1u1usul3: thread_function是由create的thread去做，main thread
→ a1u1usul3: 不會等他結束才進下一個迴圈接受新client
→ stupid0319: 應該是一次開多個accept();在accept前用mutex鎖上
→ stupid0319: 這樣就可以零時差接到下一個accept();
→ HolyBugTw: 去看mjpg_streamer的source code