【问题标题】:Drawing with ncurses, sockets and fork用 ncurses、sockets 和 fork 绘图
【发布时间】:2015-06-08 22:33:57
【问题描述】:

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

但是,我一次只能画一个客户(一个“P”)。我想在屏幕上看到很多客户('P's)。因为我现在的方式一次只使用 1 把椅子,然后客户端被出席并退出,然后 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

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

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

【问题讨论】:

    标签: c sockets fork


    【解决方案1】:

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

    • “理发师睡觉,直到有人叫醒他”

    • accept()

    如果没有某种联合等待,这种架构是行不通的。两段代码都在等待一种事件,而忽略另一种类型的事件。例如,当一个客户进来时,程序不会接受另一个客户,直到“理发师完成”。

    解决问题有两个方向:

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

    【讨论】:

      猜你喜欢
      • 2022-12-03
      • 2013-01-10
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2012-02-04
      • 1970-01-01
      相关资源
      最近更新 更多