关于akka的mailbox的size问题
2016-07-10 20:39
435 查看
在akka1.x中无论在actor内部还是外部提供了一个查询mailbox size的方法。但是在akka2.0中由于一系列的原因这一个方法被删除了。
那么查询maibox size会存在什么问题呢?
1,需要花费O(n)的时间,在queue并发大的情况下可能会很慢;)
2,并不需要精确计算size;
3,限制了扩张性;
4,在你得到size的时候,这个时候实际的size可能已经发生了非常大的变化。
来看下面的几个问题:
你为什么非要使用mailbox size呢?
假设这里有一个方法可以在actor内部探测到mailbox的size,并且探测到消息堆积太快而导致自己不能处理,那么腻将会怎么做呢?
最直接的答案是降低发送方的速度--只需要设置一个有界的queue(有界的mailbox)。
但是我想要定期的监测,并且当一个新message到来的时候打断一个常任务?
这不是一个最佳实践
那么推荐的方式是什么呢?
可以通过akka提供的resizer: dynamically resizable来分散负担,进行数据路由
如果你需要一个mailbox的metrics怎么办呢?
你能做的是实现一个自定义的mailbox,然后在自定义的mailbox里面实现你的metrics
参考:
http://letitcrash.com/post/17707262394/why-no-mailboxsize-in-akka-2
那么查询maibox size会存在什么问题呢?
1,需要花费O(n)的时间,在queue并发大的情况下可能会很慢;)
2,并不需要精确计算size;
3,限制了扩张性;
4,在你得到size的时候,这个时候实际的size可能已经发生了非常大的变化。
来看下面的几个问题:
你为什么非要使用mailbox size呢?
假设这里有一个方法可以在actor内部探测到mailbox的size,并且探测到消息堆积太快而导致自己不能处理,那么腻将会怎么做呢?
最直接的答案是降低发送方的速度--只需要设置一个有界的queue(有界的mailbox)。
但是我想要定期的监测,并且当一个新message到来的时候打断一个常任务?
这不是一个最佳实践
那么推荐的方式是什么呢?
可以通过akka提供的resizer: dynamically resizable来分散负担,进行数据路由
如果你需要一个mailbox的metrics怎么办呢?
你能做的是实现一个自定义的mailbox,然后在自定义的mailbox里面实现你的metrics
参考:
http://letitcrash.com/post/17707262394/why-no-mailboxsize-in-akka-2
相关文章推荐
- Rails的事务和锁
- Hdu 5319 Painter (模拟)
- Codeforces Round #271 (Div. 2) F. Ant colony(线段树)
- 1106. Lowest Price in Supply Chain (25)
- Exchange 2010 PS 之Set-CASMailbox!
- Repair the Wall(贪心 区间覆盖)
- 在用hadoop fs -ls 时报failed onconnetion的错误
- LeetCode 373 Find K Pairs with Smallest Sums
- 出现ping:unknow host www.baidu.com的问题解决
- leetcode 217. Contains Duplicat hash解法及相关hashmap与hashset问题
- blockchain名词解析
- find-k-pairs-with-smallest-sums
- INSTALL_FAILED_UPDATE_INCOMPATIBLE
- RAID 方案总结
- Mahout Naive Bayes中文新闻分类示例
- AAL template: ROI to brain lobe
- HDU5405 Sometimes Naive
- http://jingyan.baidu.com/album/03b2f78c4cc0ad5ea337ae7d.html
- Find K Pairs with Smallest Sums
- HDU 5009 Paint Pearls 双向链表优化DP