在hadoop jobtracker的构造初期,即JobTracker.startTracker函数里,有一句JobEndNotifier.startNotifier(); JobEndNotifier里管理一个DelayQueue,里面放置了job的信息.
JobEndNotifier管理的线程从DelayQueue中抽取作业,并向每个作业发送HTTP请求.要彻底理解JobEndNotifier类在整个JobTracker的管理职能还需要在阅读JobInProgress在内的很多类,以后再说.
这里只是记录一下DelayQueue的学习过程.
首先是UML图.有这个图会方便很多(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)(只显示文章前200个字，不显示图片)
后面一段文字不知道怎么回事就没了,这里本来还有3,400字的.算了算了,记录下自己画的UML图,以后再回头学习DelayQueue也方便.
算法导论第二部分第六章有最小堆的介绍.而最小堆就是PriorityQueue的实现算法.
Over~
阅读(897) | 评论(0) | 转发(0) |
