告诉你什么是优雅的代码(7)-----银行作业调度系统
程序员文章站
2022-05-17 21:46:24
...
公告:C1000,请到1号窗口办理,估计用时48秒。 公告:普通客户C1000进入银行。 公告:V1000,请到VIP窗口办理,估计用时31秒。 公告:vip客户V1000进入银行。 公告:C1001,请到2号窗口办理,估计用时18秒。 公告:普通客户C1001进入银行。 公告:快速客户R1000进入银行。 公告:C1002,请到3号窗口办理,估计用时18秒。 公告:普通客户C1002进入银行。 公告:C1003,请到4号窗口办理,估计用时39秒。 公告:普通客户C1003进入银行。 公告:快速客户R1001进入银行。 公告:C1004,请到快速窗口办理,估计用时15秒。 公告:普通客户C1004进入银行。 公告:快速客户R1002进入银行。 2号窗口:C1001业务办理完毕。 公告:快速客户R1003进入银行。 公告:普通客户C1005进入银行。 公告:C1005,请到2号窗口办理,估计用时36秒。 3号窗口:C1002业务办理完毕。 公告:普通客户C1006进入银行。 公告:C1006,请到3号窗口办理,估计用时47秒。 VIP窗口:V1000业务办理完毕。 公告:普通客户C1007进入银行。 快速窗口:C1004业务办理完毕。 公告:R1000,请到快速窗口办理,估计用时15秒。 公告:普通客户C1008进入银行。 公告:C1007,请到VIP窗口办理,估计用时17秒。 公告:普通客户C1009进入银行。 公告:vip客户V1001进入银行。 公告:快速客户R1004进入银行。 1号窗口:C1000业务办理完毕。 公告:C1008,请到1号窗口办理,估计用时44秒。 公告:普通客户C1010进入银行。 快速窗口:R1000业务办理完毕。 公告:R1001,请到快速窗口办理,估计用时15秒。
不要以为进了银行,上面是本期优雅代码所实现的功能。其中:
C = common customer R = rapid customer V = vip customer.
一般情况下,不同类型的窗口接应不同类型的客户。Vip与快速窗口空闲时可接受普通客户。
实现这个系统很难吗?Not at all,after reading this article ,you can!
好了,闲话休提,看下这个系统的用法:
public static void main(String[] args) { Bank bank = Bank.getInstance(); bank.open(); } public void open(){ for(int i = 1; i < 5 ; i++){ new CommonCounter(i + "号窗口").start(); } new RapidCounter("快速窗口").start(); new VipCounter("VIP窗口").start(); ...... }
由代码可知,银行开门时开了4个普通窗口,一个快速窗口,一个VIP窗口。这些窗口都是独立的线程。考虑到窗口的共性,可抽象出一个基类:
public abstract class Counter extends Thread{ protected String name; protected Bank bank = Bank.getInstance(); protected boolean working = false; public Counter(String name){ this.name = name; } public void run(){ working = true; while(working){ String cust = callCust(); long needTime = genProcessTime(); System.out.println(new StringBuffer().append("公告:").append(cust).append(",") .append("请到").append(name).append("办理,估计用时"). append(needTime).append("秒。")); try { Thread.sleep(needTime * 1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(new StringBuffer().append(name) .append(":").append(cust).append("业务办理完毕。")); } } protected abstract String callCust(); protected abstract long genProcessTime(); }
看清楚了吗,这个基类完成了呼叫的主要逻辑,其中有两个抽象方法,留给不同的特殊窗口去实现。一个是呼叫客户的规则callCust,一个是窗口处理时间的评估函数。特殊窗口的代码?留给聪明的你了。
OK,下面请出这个系统的主角:
BlockingQueue
是不是有点陌生,是就去翻下api了。这个东西有两个特长,线程安全与阻塞,有了这个实力派主角,什么生产者消费者模型都可以轻松实现。
上面这句话已经点题了,啊?生产什么?消费什么?
生产客户,消费客户!
我们为三种客户排个队吧:
BlockingQueue<String> commonCusts = new ArrayBlockingQueue<String>(10); BlockingQueue<String> rapidCusts = new ArrayBlockingQueue<String>(10); BlockingQueue<String> vipCusts = new ArrayBlockingQueue<String>(10);
现在已经很明朗了,如何生产客户,请听下回分解。
上一篇: 浅谈PHP中Stream(流),浅谈phpstream
下一篇: 如何防止HA集群的脑裂