我正在尝试编写一个服务器程序，该程序 fork 一个进程来处理多个客户端连接，每个连接创建一个线程。但是这个进程可以创建的最大线程数永远不会超过 382。

为什么在 Linux 中每个进程的文件描述符限制为 1024，而我不能创建更多数量的线程来处理一个文件描述符以与一个客户端通信？

我使用的系统在 Core-i3 上运行 Kubuntu，内存为 2GB。

这是main函数的代码..

int server_start(void)
{
listen(skid,10000);
scnt=0;
printf("Server Listening at port:%d\n",serdt.port);
for(scnt=0;scnt<1000;)
{
        sdata->cpid[scnt]=fork();
        switch(sdata->cpid[scnt])
        {
            case -1:    printf("Could not Fork\n"); break;
            case  0:    mxsubserver(scnt); exit(0);
            default:    scnt++; break;
        }
//  }
    //check for other parameters
    pause();
}
while(1);
}

函数中未声明的变量是全局变量。我有一个用于中断暂停的信号编号 50 的空白操作处理程序。

当达到限制(文件描述符)时， fork 进程向父(本)进程发送信号，然后它将 fork 一个新进程。下面是上面代码中fork之后调用的服务器进程代码...

typedef struct
{
    int cln;
    int cnt;
    int fd;
    pthread_t ptid;
}service_d;

void mxsubserver(int cln)
{//cln is the child sub-server number
int ln,fd,rfp;
pthread_t ptid;
pthread_attr_t attr;
iflag=1;

sub_data = shmat(shmid,NULL,SHM_RND);

signal(SIGINT,sub_sigint);
signal(SIGPIPE,sub_sigpipe);
signal(50,SIG_DFL);
parg = malloc(sizeof(service_d));
parg->cln = cln;
cnt=0;
printf("Server Instance %d Started\n",cln);
for(cnt=0;;)
{
    if(iflag)
    {
        cnt++;
        ln = (socklen_t)sizeof(struct sockaddr_in);
        fd = accept(skid,(struct sockaddr *)&sktaddr,&ln);
        parg->fd=fd;
        parg->cnt=(cln*1000)+cnt;
        pthread_attr_init(&attr);
        pthread_create(&(parg->ptid),&attr,&service,parg);
        pthread_detach(parg->ptid);
        pthread_attr_destroy(&attr);
        sub_data->openfd[cln]=cnt;
    }
    if(cnt>=1000)
    {
        printf("Limit Reached\n");
        iflag=getppid();
        printf("Signalling Parent\n");
        kill(iflag,50);
        iflag=0;
        pause();
    }
    if(cnt==0)
    {
        free(parg);
        exit(0);
    }
}
kill(getppid(),50);
while(1);
return;
}
void sub_sigint(int sn)
{
free(parg);
shmdt(sub_data);
exit(0);
}

void sub_sigpipe(int sn)
{
cnt--;
iflag=1;
}

void* service(void *arg)
{//handle the client requests
int fd,cln,l,ol;
char im[100],*msg="This is from Server\n";
service_d *srd;

srd = (service_d*)arg;
//pthread_detach(srd->ptid);
fd = srd->fd;
cln = srd->cnt;
printf("service cln: %d f: %d\n",cln,iflag);
ol=strlen(msg);

while(1)
{
    read(fd,&l,sizeof(int)); //open to get sigpipe error if client closes
    if(read(fd,im,l)<0) break;
    im[l]='\0';
//  printf("Server %d thread %d: Got >> %s\n",srd->cln,cln,im);
    if(write(fd,&ol,sizeof(int))<0) break;
    if(write(fd,msg,ol)<0) break;;
}
close(fd);
pthread_exit("Done\n");
}

谢谢。

最佳答案

解决了。

看到这个帖子:Threads/Sockets limits in Linux

默认堆栈大小为 8MB。当我创建 382 个线程时，为所有线程创建的堆栈的总大小为 8x382，即大约 3GB。

因此，我使用 pthread_attr_setstacksize 将堆栈大小减少到 30KB。 现在在连接到大约 6000 个客户端后，它必须说类似 libgcc_s.so.1 must be installed for pthread_cancel to work 。这可以通过运行以下命令来解决:apt-get install libgcc1-dbg as root。

关于c - Stream Socket Server 在 Linux 中不能处理超过 382 个线程(每个连接一个)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31557156/