我当前正在开发的应用程序是一个服务器,它将使用 select() 管理与客户端的连接,每次服务器收到消息时,它将打开一个新线程以读取套接字。在此期间,套接字的文件描述符将从集合中删除,并将在读取结束时添加。 这是代码示例
struct s_handle {
int sock;
fd_set * rdfs;
};
int main(){
...
fd_set rdfs;
...
while(1){
....
select(nb_fd,&rdfs,NULL,NULL,NULL)
for_each(peer){
if(FD_ISSET(peer->sock,&rdfs)){
struct s_handle * h = malloc(sizeof(struct s_handle));
h->sock = peer->sock;
h->rdfs = &rdfs;
FD_CLR(peer->sock,&rdfs);
pthread_create(thread,NULL,handle,(void *)&h);
}
}
...
}
...
}
void* handle(void* argss){
struct s_handle * temp = (struct s_handle *) argss;
...
FD_SET(temp->sock,temp->rdfs);
}
FD_SET、FD_ISSET 和 FD_CLR 是原子操作吗?还是需要用互斥体锁定 rdfs?
如果需要互斥锁,如何避免死锁?
最佳答案
首先,您不应该创建这样的线程。创建线程是一项相当高的开销操作,仅当您需要更多线程时才应使用,而不仅仅是因为您必须做更多工作。
是的,您确实需要使用互斥锁来保护 FD_*
函数。通常的解决方案是使用一个互斥锁,仅在执行 FD_*
操作所需的瞬间保留该互斥锁。在调用 select
之前,您需要获取互斥锁,制作描述符集的副本,然后释放互斥锁。
一般来说,从读取集中删除套接字并不是一个好主意。将套接字放回读取集中不会更改稍后已经发生的select
。而且您将很难弄清楚如何让调用 select
的线程脱离 select
以便对新集合进行操作。
您可能需要重新考虑 I/O 发现方法并使用标准方法之一,而不是尝试推出自己的方法。您被迫进行丑陋的权衡,要么让某些套接字未被监听以进行读取,因为最近读取了这些套接字,并且 select
仍然被阻止,或者必须重新select
作为您完成了从每个套接字的读取。这两种解决方案都不好。
一种更常见的模式是在读取套接字时将套接字保留在集合中,并且在读取所有套接字(但不一定已处理其数据)之前不返回 select
)。
关于c - FD_SET、FD_CLR ...是原子操作吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9457536/