使用 ncurses、sockets 和 fork 绘图

Question

所以我正在处理理发店问题，但现在我想让它 'visual' 并且对网络友好。当服务器启动时，等待客户端连接，每次客户端连接时，它都会绘制一个 'P' 在屏幕上移动直到理发师位置。我用 NCurses 做这件事，我对此没有问题。

但是我一次只能画一个客户（一个'P'）。我希望在屏幕上看到很多客户 ('P's)。因为我现在的方式是一次只使用一把椅子，然后客户参加并退出，然后 accept() 队列中的下一个客户进入屏幕，依此类推。它给人的印象是没有实际的并发想法。

我有一个非常广泛的代码，但 fork/socket 部分在这里：

pid_t client;
int p;
RandSeed=8;
 listen(connection,90);
 while(1){
     remote_dir_size = sizeof(remote_dir);
    //"Awaiting connection...
     if((connection_client=accept(connection,(struct sockaddr *)&remote_dir,&remote_dir_size))<0){
         console_write("CONNECTION REJECTED!");
         exit(-1);
     }
    //"Connection accepted!
     client=fork();
     switch(client)
     {
         case -1:
            console_write("Error Forking!!");
            exit(1);
         case 0:
            close(connection); //So that another client can come.
            recvs = recv(connection_client,petition,sizeof(petition),0);
            
             //console_write(petition);
            // console_write(" moviendose.");
             move_client();
            
             //Check for avialable chairs
            
             //waiting_client_count++;
             sem_wait(waitingRoom); //wait until available
             move_client_to_chairs();
             sitting_client_count++;                
             redraw_chairs();  //redraw chair <--Useless since only 1 chair is used at a time :/
             //waiting for barber
              
             sem_wait(barberChair);
             
             //barber available, chair occupied is now free
             sem_post(waitingRoom);
             sitting_client_count--;
             redraw_chairs();
             
             move_client_to_barber(); //Move 'P' towards barber chair
             sit_client_barber();
             //Wake barber
             sem_post(barberPillow);
            
             //Wait until barber ends
            
             sem_wait(seatBelt);
             //release chair
             sem_post(barberChair);
             exit_client();
   
             exit(0);
         default:
            
            //barber sleeps until someone wakes him
                             
            sem_wait(barberPillow);
            randwait(5);
            //barber cutting hair
            randwait(5);
            //barber finished
            //free client
            sem_post(seatBelt);
            wait(&p);        
     }
}

完整版代码为here

我的问题是：服务器启动良好。然后当我运行 a ./client 服务器屏幕开始沿着屏幕绘制 P 并且它正确移动它时，客户端得到它的理发并退出。但是当我运行 2 或更多 ./clients 服务器屏幕一次绘制一次过程时，理发店内一次只有一个客户；就好像它在等待那个客户端 exit() 以启动下一个 forked 进程。

我觉得这很奇怪，我在这里错过了什么？是accept队列的问题吗？我应该尝试不同的视角吗？

Answer 1

问题是您的父进程正在尝试做两件需要等待的不同事情：

"barber sleeps until someone wakes him"
accept()

如果没有某种联合等待，这种架构是行不通的。两段代码都在等待一种事件，而忽略另一种类型的事件。例如，当一个客户进来时，程序直到"barber finished".

才会接受另一个客户

解决问题有两个方向：

加入两种等待：对于accept()，可以将socket转为非阻塞模式，使用select()或poll()等到有事件进来，对于信号量来说，这不是那么微不足道，但是如果你在父子之间打开一个套接字，并将信号量处理变成网络通信，你可以有一个 select() 或 poll() 等待对于所有套接字（一个用于接收新的客户端连接，每个客户端一个用于与它们通信）在一个地方。您还必须重新设计信号量处理 - 并摆脱那里的睡眠，例如保留活动计时器列表，然后返回 select() 或 poll() 直到下一个计时器超时（他们的最后一个参数可以限制最长等待时间。
将accept()和信号量处理一分为二进程，即父进程正在处理新的传入连接，和一个子进程 "simulates" 理发师。其实，你的方式试图实现 "barber"，你需要每个子进程理发师，因为模拟工作时进程正在休眠理发师做的。或者你重新设计 "barber" 模拟，如第一部分所述。

使用 ncurses、sockets 和 fork 绘图

Drawing with ncurses, sockets and fork

c

sockets

fork