假设我需要一个Scala组件来并发处理传入的请求并返回处理结果。还假设请求处理由几个步骤组成。其中一些步骤是资源和时间消耗的,有些是I/O或CPU限制的,等等。
假设请求来自JVM内部,我将按以下方式设计组件:
Futures异步执行处理步骤,然后包装这些步骤Future回调实现的。说得通吗?在Scala中有这样一个组件的好例子吗?
发布于 2013-04-13 22:25:01
考虑到你展示的细节,这是有意义的。
对于这种情况,一个很好的框架是阿克卡。请参阅源代码中的示例,以及GitHub中的许多开源项目。
https://stackoverflow.com/questions/15987363
复制相似问题