关于队列,使用的地方非常的多。现实中有很多的例子。比如医院的挂号系统,银行里的叫号系统,食堂里的排队打饭等等。市场上又这样的排队取号的设备。他们的功能基本如下：

1、系统可联网联机统一发号；
2、系统可无线对接，也可有线连接；
3、系统支持100种业务以上；
4、系统支持多个等候区提示等候信息，各等候区语音及显示可独立；
5、个性化语音可呼叫客户所办理的业务名称（医院版可呼叫病人姓名）等信息；
6、号码可在不同服务类别的柜台窗口之间相互转移，顾客不必重复排队；
7、具备登录操作功能和退出操作功能：工作开始前，输入员工登陆号进行登录，工作结束后，退出排队系统，这对统计非常准确；
8、发号机界面的图片客户完全可以按个性化自主设计更换；
9、各项业务的按键客户完全可以按个性化自主设计更换；
10、支持通过读卡器读取客户相关信息后，自动区分VIP客户和普通客户，自动区分对公客户和对私客户，并按营业机构自定的排队规则自动编组排队；
11、号票上和发号机上的显示屏会显示每个顾客前面的等待人数；
12、各项业务队列客户完全可以自主按需任意增减；
13、各项业务的等待人数客户完全可以自主设定在界面上显示并可任意排版；
14、各项业务的工作时段及暂停时段客户完全可以自主设定；
15、操作员工的增减及登陆账号客户完全可以自主更改；
16、语音呼叫的信息客户完全可以自主按个性化更改；
17、显示屏的任何显示信息客户完全可以自主按个性化更改；
18、顾客办理各项业务的序号客户完全可以自主设置，如：贵宾业务或理财金业务可设为1-200号内、外币业务可设为201-500号内、人民币业务设501-9999号内；
19、工作员工所办理的业务队列客户完全可以自主任意设置优先级；
20、号票上的文字内容、图案、业务名称、时间格式、更改字体及大小、纸张长短等客户完全可以自主按个性化设置；
21、系统支持播放背景音乐，音乐曲目完全由客户自主选择；
22、系统支持在值班经理处增设监控软件，处理各种特殊状况；
23、系统支持高清晰度等离子显示器、大屏幕、电视墙等多种显示设备，显示丰富的排队信息；
24、系统支持连接互联网络，可实现远程监控；
25、系统设有扩展功能，当需要有关统计和管理数据时，可热键激活管理软件并打印；
26、系统可根据需要配置客户评价器及排队信息（短信）提示功能。

OK，了解了这些后，我们来实现一个简单的例子吧！先看看效果图：

废话不多说了，看代码：

CallNum.java

package com.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
/**
 * @see 模拟银行叫号系统
 * @author Herman.Xiong
 * @date 2014年11月17日 14:48:48
 * @version V1.0
 */
public class CallNum {
	public static void main(String[] args) throws InterruptedException {  
		//创建服务中心,如一个银行的营业厅
		Center center = new Center();  
        ExecutorService exec = Executors.newCachedThreadPool();  
        //模拟产生服务人员
        Producer producer = new Producer(center);  
        //模拟产生N多客户
        Consumer consumer = new Consumer(center);  
        exec.execute(producer);  
        //模拟10名客户
        for (int i = 0; i < 10; i++) {  
            exec.execute(consumer);  
        }  
        TimeUnit.SECONDS.sleep(10);  
        exec.shutdown();  
        //如有疑问,请加QQ群：135430763共同学习！
    }
}

package com.test;

import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
/**
 * @see 服务中心
 * @author Herman.Xiong
 * @date 2014年11月17日 14:41:28
 * @version V1.0
 */
public class Center extends Thread {  
    private final static int MAXCOUNT = 10;  
  
    private BlockingQueue<Waiter> waiters;  
    private BlockingQueue<Customer> customers;  
  
    private Random rand = new Random(47);  
  
    private final static int PRODUCERSLEEPSEED = 100;  
    private final static int CONSUMERSLEEPSEED = 10000;  
  
    public Center() {  
    	//创建10名提供服务的工作人员
        this.waiters = new LinkedBlockingQueue<Waiter>(MAXCOUNT);  
        for (int i = 0; i < MAXCOUNT; i++) {  
            waiters.add(new Waiter());  
        }  
        //10名工作人员工作就绪,创建客户队列
        this.customers = new LinkedBlockingQueue<Customer>();  
    }  
  
    public void produce() {  
        try {  
            TimeUnit.MILLISECONDS.sleep(rand.nextInt(PRODUCERSLEEPSEED));  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        this.customers.add(new Customer());  
    }  
  
    public void consume() {  
        try {  
        	
            // 服务窗口可用  
            Waiter waiter = this.waiters.take();  
            this.waiters.remove(waiter);  
            
            // 客户可用  
            Customer customer = this.customers.take();  
            this.customers.remove(customer);  
  
            // 窗口显示  
            System.out.println(waiter + "正在为" + customer + "服务...");  
            TimeUnit.MILLISECONDS.sleep(rand.nextInt(CONSUMERSLEEPSEED));  
  
            this.waiters.add(waiter);  
        } catch (InterruptedException e) {  
            System.err.println("---" + e.getMessage());  
        }  
    }  
} 

package com.test;
/**
 * @see 生产者线程,模拟银行工作人员服务完成一位客户后开始准备服务下一位客户
 * @author Herman.Xiong
 * @date 2014年11月17日 14:55:43
 * @version V1.0
 */
public class Producer implements Runnable {  
    private Center center;  
  
    public Producer(Center center) {  
        this.center = center;  
    }  
  
    @Override  
    public void run() {  
        while (!Thread.interrupted()) {  
        	//产生客户
            center.produce();  
        }  
    }  
}  

package com.test;
/**
 * @see 模拟客户完成业务需求后,服务人员空闲就绪
 * @author Herman.Xiong
 * @date 2014年11月17日 14:57:11
 * @version V1.0
 */
public class Consumer implements Runnable {  
    private Center center;  
  
    public Consumer(Center center) {  
        this.center = center;  
    }  
  
    @Override  
    public void run() {  
        while (!Thread.interrupted()) {  
            center.consume();  
        }  
    }  
  
}  

关于大家关注我的博客！如有疑问,请加QQ群：135430763共同学习！

叫号系统排队系统挂号系统实现