该楼层疑似违规已被系统折叠 隐藏此楼查看此楼
简单优化了下，下班就10点了。。
package com.hd.thread.bank;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingQueue;
public class BankService {
// 客户等待队列
private LinkedBlockingQueue waitQueue;
// 服务线程监控
CountDownLatch latch;
// 服务窗口数
private int seriveNum;
// 客户处理完成后进入汇总集合
private List collectList;
// 服务窗口线程组,响应中断用
ThreadGroup tg;
public BankService() {
// 只有20把椅子
this.waitQueue = new LinkedBlockingQueue<>(20);
// 默认4个服务窗口
this.seriveNum = 4;
latch = new CountDownLatch(seriveNum);
// 初始化汇总集合为线程安全集合
this.collectList = Collections.synchronizedList(new ArrayList<>());
// 默认为true 结束为false
// this.flowFlag = true;
tg = new ThreadGroup(“服务窗口线程组”);
}
public BankService(int seriveNum) {
this();
this.seriveNum = seriveNum;
latch = new CountDownLatch(seriveNum);
}
/**
* 客户到达银行，入队
*
* @param c
*/
public void come(List customers) {
new Thread() {
public void run() {
System.out.println(“银行大门打开，开始排队：”);
for (Customer c : customers) {
try {
// 假设50毫秒进来一个客户
Thread.sleep(50);
waitQueue.put(c);
System.out.println(“客户：” +c+”进入等待队列”);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println(“客户全部被服务”);
// flowFlag = false;
}
}.start();
}
/**
* 服务主方法
*/
public void service() {
// 窗口服务结果
for (int i = 0; i < seriveNum; i++) {
// 窗口号默认按照线程执行顺序
final int n = i + 1;
final Counter counter = new Counter();
new Thread(tg, String.valueOf(n)) {
public void run() {
try {
System.out.println(“窗口：【” + n + ” 】开始工作”);
// 从等待队列中提取需待服务客户
Customer c;
while (true) {
try {
c = waitQueue.take();
} catch (InterruptedException e) {
System.out.println(“窗口：【” + n + ” 】下班喽”);
break;
}
c.setCounter(n);
// 模拟处理过程
handle(c.getServices());
// 窗口统计
counter.inc(c.getServices());
// 处理完成设置完成时间
c.setFinshTime(System.currentTimeMillis());
// 将客户移到汇总集合中
collectList.add(c);
System.out.println(
“窗口：【” + n + ” 】完成了编号：【” + c.getNum() + “】的客户业务工作”);
// 释放掉引用
c = null;
}
// 完成工作
System.out.println(“窗口：【” + n + ” 】完成工作” + counter.toStr());
} finally {
latch.countDown();
}
}
}.start();
}
try {
latch.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 客户平均逗留时间
*
* @return
*/
public long getAvgTime() {
long time = 0l;
for (Customer c : collectList) {
time = time + (c.getFinshTime() – c.getEnterTime());
}
return time / collectList.size();
}
/**
* 每个窗口的时间段内的工作成果
*
* @author Administrator
*
*/
class Counter {
// 服务客户数
private int customerNum;
// 提供服务类型数Map
private Map serviceTypeNumMap;
Counter() {
this.serviceTypeNumMap = new HashMap<>(4);
}
public String toStr() {
String serviceTypeNum = “”;
for (Entry entry : serviceTypeNumMap.entrySet()) {
serviceTypeNum = serviceTypeNum + Service.getService(entry.getKey()).getTypeName() + “:” + entry.getValue() + “次 “;
}
return “服务客户数:” + customerNum + “；提供的服务类型和类型数：” + serviceTypeNum;
}
public void inc(List services) {
cinc();
sinc(services);
}
/**
* 提供服务数自增
*/
private void cinc() {
customerNum++;
}
/**
* 提供服务类型数
*/
private void sinc(List services) {
Integer typeNum = null;
for (Service s : services) {
typeNum = serviceTypeNumMap.get(s.getType());
if (typeNum == null)
serviceTypeNumMap.put(s.getType(), 1);
else
serviceTypeNumMap.put(s.getType(), typeNum + 1);
}
}
public int getCustomerNum() {
return customerNum;
}
}