【发布时间】:2009-07-02 14:27:21
【问题描述】:
我正在尝试开发一种服务,该服务包含通过IO::Select 同步轮询的大量客户端和服务器套接字(服务器服务以及连接到托管组件并持续存在的客户端)。这个想法是处理通过工作线程池产生的 I/O 和/或请求处理需求。
在 Perl (threads::shared) 中使数据可跨线程共享的 shared 关键字有其局限性——句柄引用不在可共享的原语中。
在我发现无法共享句柄和/或句柄引用之前,计划是有一个 select() 线程来处理轮询,然后将相关句柄放在某个 ThreadQueues 中,分布在一个线程池来实际进行读写。 (当然,我是这样设计的,以便对select 使用的实际描述符集的修改将是线程安全的,并且只发生在一个线程中——运行select() 的同一线程,因此永远不会很明显,正在运行。)
这似乎不会发生,因为句柄本身不能共享,因此轮询以及读取和写入都需要从一个线程进行。有什么解决方法吗?我指的是跨线程的实际系统调用的分解;显然,有一些方法可以使用队列和缓冲区让数据在其他线程中生成并在其他线程中实际发送。
这种情况产生的一个问题是我必须给select() 一个超时,并期望它足够高而不会导致轮询相当大的一组描述符时出现任何问题,同时又足够低而不会引入我的计时事件循环延迟过多 - 不过,我明白如果在轮询过程中检测到实际的 I/O 集成员资格,select() 将提前返回,这在一定程度上缓解了问题。我宁愿有某种方法从另一个线程唤醒select(),但由于无法共享句柄,我无法轻易想到这样做的方法,也看不到这样做的价值;无论如何,其他线程会知道什么时候适合唤醒select()?
如果没有解决方法,那么在 Perl 中,这种类型的服务有什么好的设计模式?我需要相当高的可扩展性和并发 I/O,因此走的是非阻塞路线,而不是仅仅为每个侦听套接字和/或客户端和/或服务器进程生成线程,因为许多人使用更高-如今,在处理套接字时不习惯使用级别语言——这似乎是 Java 领域的一种标准做法,在面向系统编程的狭窄领域之外,似乎没有人关心java.nio.*。也许这只是我的印象。反正我不想那样做。
那么,从经验丰富的 Perl 系统程序员的角度来看,应该如何组织这些东西?单片 I/O 线程 + 纯工作(非 I/O)线程 + 大量队列?某种聪明的hack?除了我已经列举的之外,还有什么需要注意的线程安全问题吗?有没有更好的办法?我在用 C 语言构建此类程序方面拥有丰富的经验,但没有 Perl 习惯用法或运行时特性。
编辑:附注我确实想到,也许一个具有这些性能要求和这种设计的程序根本不应该用 Perl 编写。但是我看到 Perl 产生了很多非常复杂的服务,所以我不确定。
【问题讨论】:
标签: perl multithreading sockets nonblocking