关于队列,使用的地方很的多。

现实中有许多的样例。

比方医院的挂号系统,银行里的叫号系统,食堂里的排队打饭等等。市场上又这种排队取号的设备。他们的功能基本例如以下：

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共同学习！