最近遇到一个开发case:我们提供有限的资源服务,当资源不足时,需要排队,同时当轮到某个人使用时,要通知他来使用,如果一定时间他还没有来用,需要通知下一个排队人,这个场景有没有很熟悉?没错就是我们去吃饭时候的排队叫号,去银行时候的排队叫号,买房子排队摇号,可以说在服务人数超过资源限制的场景都会用到,接下来说一下我的实现方案
语言:java
用到的java类:
1)ArrayBlockingQueue 保证先进先出的队列顺序
2)ScheduledThreadPoolExecutor:超时检测,通知下一个
算法:递归
伪代码:
String currentWaitingPerson=""; //当前轮到的那一位
boolean resourceBusy = false //默认不需要排队
if(resourceBusy && !person.equals(currentWaitingPerson)){
ArrayBlockingQueue.put(person)
}
else{
person 去使用资源
}
//当前使用资源的人任务结束,释放掉资源,需要通知下一个排队人
function notifyWaitingPerson(){
if(currentTask is end){
person = ArrayBlockingQueue.take()
currentWaitingPerson = person
if(null!=person){
notify(person)
schedule.execute(new Runnable({
if(person 没有来使用资源){
//递归调用,通知下一个
notifyWaitingPerson()
}
}),指定一个超时时间)
}
}
}
如果有排队的人过号了,又来询问,看自己的机制了,如果需要排在队列头,blockingQueue换成priviorityQueue即可,如果是过号重排的话,直接放到队尾即可
有更好的干货?欢迎来闻道课堂分享你的知识,知识付费的新平台