服务器多线程编程，这么写对不对

mrpre

tcp服务器程序:

1. int main()
   
2. {
   
3.     .........
   
4.     .........
   
5.     int listenfd,connectfd;
   
6.     char buff[1024];
   
7.     pthread_t ptid;
   
8.     listenfd=listen(..);
   
9. 
   
10. 
    
11.     while(1)
    
12.     {
    
13.         connectfd=accept( listenfd , struct sockaddr*addr...);
    
14.         recv(...,buf,...)
    
15.         pthread(&ptid,NULL,fun,(void *) buf);
    
16. }
    
17. 
    
18.     return 0;
    
19. }
    
20. 
    
21. void fun(void * buf)
    
22. {
    
23.   
    
24.   printf("%d",(char *) buf);//问题1：线程1进入fun但printf还没调用前，cpu切换到线程2，也就是在第二次accept和receive后，cpu又切换到线程1，但此时buff里面是线程2的数据，如何避免
    
25.    
    
26. //函数结束时要不要关闭connectfd，close(connectfd)
    
27. }

复制代码

udp服务器程序:



int main()
{
    ......
    int fd,ptid;
    char buff[512];
    struct sockaddr_in clientAddr;//用来存储客户端传来的信息
    int n;
    int len = sizeof(clientAddr);
    while(1)
    {
        n = recvfrom(sock, buff, sizeof(buff), 0, (struct sockaddr*)&clientAddr, &len);
        if (n>0)
        {
            pthread_t ptid;
            pthread_create(&ptid,NULL,fun,(void*) clientAddr);
        }

    return 0;
}

void fun(void *arg)
{
   
    printf("%d",(struct sockaddr_in) arg.sin_addr.s_addr);//问题同 问题1
    //函数结束时要不要关闭connectfd，close(connectfd)
}

myworkstation

回复 1# mrpre


    TCP的问题：
　１、socket没看到设置nonblocking，accept之后把上recv会导致主线程阻塞其它的连接这时将得到不处理，如果连接较多的话问题就更严重了。
　２、没看到使用任何多路复用的事件模型。效率低下
　３、一个连接对应一个线程的方式已成为历史了，除非连接的量非常少。


　UDP的问题：
　和TCP类似。


　总结：这个代码是学习性代码，基本不具备真实环境的实用性（除非程序逻辑简单到了极至）

nameofhsw

TCP为例的话，一般是accept后，创建新的线程去recv，也就是说recv的操作应该是在你的fun函数中处理的，所以不会有你说的buf的问题。
如果你使用的是容器或者全局变量，那么去查下“线程锁”
最好还学习上上面说的I/O多路复用，即select/poll/epoll

aaadddzxc

我连问题都没看懂

djsxut

学习的代码， accept后fork新的进程处理recv， 就不会冲突。 也不会阻塞主进程处理其它的连接请求。以后可以尝试用IO多路复用.

redor

回复 1# mrpre


    最好是先初始化一堆线程，一个连接来的时候去找空闲线程，用完回收线程

cunixc

//问题1：线程1进入fun但printf还没调用前，cpu切换到线程2，也就是在第二次accept和receive后，cpu又切换到线程1，但此时buff里面是线程2的数据，如何避免
   


判断cpu状态位;
int i,j;
即epoll 或poll....