最近遇到一个开发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即可，如果是过号重排的话，直接放到队尾即可
有更好的干货？欢迎来闻道课堂分享你的知识，知识付费的新平台
闻道课堂
网友评论