gpt4 book ai didi

c - 使用 ncurses、sockets 和 fork 绘图

转载 作者:太空宇宙 更新时间:2023-11-04 01:03:08 25 4
gpt4 key购买 nike

所以我正在处理理发店问题,但现在我想让它“可视化”并且对网络友好。当服务器启动时,等待客户端连接,每次客户端连接时,它都会绘制一个“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

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

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

最佳答案

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

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

  • 接受()

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

解决问题有两个方向:

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

关于c - 使用 ncurses、sockets 和 fork 绘图,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30720202/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com