package Chapter17.bank;
import java.awt.BorderLayout;
import java.awt.Button;
import java.awt.FlowLayout;
import java.awt.Frame;
import java.awt.GridLayout;
import java.awt.Label;
import java.awt.Panel;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
public class SimulationSite extends Frame implements ActionListener {//模拟现场场景
//定义全局成员常量
protected static final int num_agents=10;
protected static final int num_initial_agents=6;
protected static final int max_customer_delay=9000;
protected static final int max_teller_break=1000;
protected static final int max_no_customers=2000;
//创建Button组件
private Button open = new Button("开门");
private Button close = new Button("关门");
private Button add = new Button("欢迎光临");
private Button del = new Button("请慢走");
private Bank bank = new Bank();
private Finance supermarket = new Finance("");
//添加窗口关闭事件
private class WindowCloser extends WindowAdapter{
public void windowClosing(WindowEvent e){
bank.stop();
supermarket.stop();
System.exit(0);
}
}
public SimulationSite(){//构造方法，进行组件初始化和布局
super("SimulationSite");
Panel buttons = new Panel();
buttons.setLayout(new FlowLayout());
buttons.add(open);
open.addActionListener(this);
buttons.add(close);
close.addActionListener(this);
buttons.add(add);
add.addActionListener(this);
buttons.add(del);
del.addActionListener(this);
this.addWindowListener(new WindowCloser());
this.setLayout(new BorderLayout());
add("West",bank);
add("East",supermarket);
add("South",buttons);
validate();
pack();
show();
bank.start();
supermarket.start();
}
public void actionPerformed(ActionEvent e) {//为单击按扭做事件监听
// TODO Auto-generated method stub
if(e.getSource()==open){
bank.openDoor();
supermarket.openDoor();
}else if(e.getSource()==close){
bank.closeDoor();
supermarket.closeDoor();
}else if(e.getSource()==add){
bank.addAgent();
supermarket.addAgent();
}else if(e.getSource()==del){
bank.retireAgent();
supermarket.retireAgent();
}
}
public static void main(String[] args){//本程序的入口处
SimulationSite sl = new SimulationSite();
}
}
class Finance extends Panel implements Runnable {
protected Penson[] person = new Penson[SimulationSite.num_agents];
protected Label[] labelAgent = new Label[SimulationSite.num_agents];
protected Label labelQueue = new Label("已服务的顾客数:0");
protected Label labelServed = new Label("Customers servers:0");
protected Label labelWait = new Label("Customers wait:0");
protected int numAgents = SimulationSite.num_initial_agents;
protected int numCustomer = 0;// 顾客数
protected long totalWait = 0L;// 等待顾客数
private Thread thread = null;
private boolean doorIsOpen = false;
public Finance(String title) {
super();
setup(title);
}
public void updateDisplay() {
}
public void generateCustomer() {
}
public Customer requestCustomerFor(int id) {
return null;
}
public void checkoutCustomer(int handled, long waitTime) {// 更新顾客的数量，和正在等待的总人数
numCustomer++;
totalWait += waitTime;
}
public void addAgent() {// 增加人员
if (numAgents < SimulationSite.num_agents) {
person[numAgents] = new Penson(this, numAgents);
person[numAgents].start();
numAgents++;
}
}
public void retireAgent() {// 减少人员
if (numAgents > 1) {
person[numAgents - 1].setRunING();
numAgents--;
}
}
public void start() {
if (thread == null) {
thread = new Thread(this);
doorIsOpen = true;
thread.start();// 启动当前线程
for (int i = 0; i < numAgents; i++) {
person[i].start();// 启动Person类中的线程
}
}
}
public void stop() {
doorIsOpen = false;
thread = null;
for (int i = 0; i < numAgents; i++) {
person[i].setRunING();
}
}
public void openDoor() {// 营业
doorIsOpen = true;
}
public void closeDoor() {// 打烊
doorIsOpen = false;
}
public void run() {// 重写Runnable的run方法
while (thread == Thread.currentThread()) {
try {
thread.sleep((int) Math.random()
* SimulationSite.max_no_customers);
if (doorIsOpen) {
generateCustomer();
updateDisplay();
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
private void setup(String title) {// 设置状态
Panel agentPanel = new Panel();
agentPanel.setLayout(new GridLayout(SimulationSite.num_agents + 3, 1));
for (int i = 0; i < SimulationSite.num_agents; i++) {
labelAgent[i] = new Label("Penson" + i + ":served 0");
agentPanel.add(labelAgent[i]);
person[i] = new Penson(this, i);
}
for (int i = numAgents; i < SimulationSite.num_agents; i++) {
labelAgent[i].setText("Penson" + i + ":inactive");
}
agentPanel.add(labelQueue);
agentPanel.add(labelServed);
agentPanel.add(labelWait);
setLayout(new BorderLayout());
add("Center", agentPanel);
add("North", new Label(title));
}
}
class Penson extends Thread {// 创建一个Thread类的子类Penson类
private boolean running = false;// 是否停止运行的标志
private Finance bn = null;
private int id = -1;// 客户id
private int numCustomers = 0;// 顾客数量
public Penson(Finance _bn, int _id) {
this.bn = _bn;
this.id = _id;
}
public void start() {
running = true;
super.start();// 启动线程
}
public void setRunING() {// 设置执行状态
running = false;
}
public int getNum() {// 获取顾客数量
return numCustomers;
}
private void releaseCustomer(Customer customer) {// 释放顾客对象
numCustomers++;
bn.checkoutCustomer(numCustomers, customer.getWaitTime(new Date()));
}
public void run() {// 重写Thread的run方法
while (running) {
try {
sleep((int) (Math.random() * SimulationSite.max_teller_break) + 1000);// 随面休眠
Customer customer = bn.requestCustomerFor(id);
if (customer != null) {
sleep(customer.getDelayTime());
releaseCustomer(customer);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Bank extends Finance implements Runnable {
private ObjectQueue queue = null;
public Bank() {
super("中国北京银行");// 调用父类的带参构造方法
queue = new ObjectQueue();// 创建ObjectQueue对象
}
public void updateDisplay() {// 更新显示
labelServed.setText("已服务的顾客数:" + numCustomer);// 设置标签的显示内容
if (numCustomer != 0) {
labelWait.setText("平均等待:" + (totalWait / numCustomer));
for (int i = 0; i < numAgents; i++) {
labelAgent[i].setText("顾客:" + i + ": 已服务" + person[i].getNum());
}
for (int i = numAgents; i < SimulationSite.num_agents; i++) {
labelAgent[i].setText("顾客:" + i + ": 未服务");
labelQueue.setText("正在等待的顾客数:" + queue.getSize());
}
}
}
public void generateCustomer() {// 增加新的顾客，表示又有新的顾客光临
queue.insert(new Customer());
}
public Customer requestCustomerFor(int id) {// 表示有顾客发出想进行服务的需求
return queue.requestCustomer();
}
}
//class SimulationSite extends Frame implements ActionListener {// 模拟现场场景
// // 定义全局成员常量
// protected static final int num_agents = 10;
// protected static final int num_initial_agents = 6;
// protected static final int max_customer_delay = 9000;
// protected static final int max_teller_break = 1000;
// protected static final int max_no_customers = 2000;
// // 创建Button组件
// private Button open = new Button("开门");
// private Button close = new Button("关门");
// private Button add = new Button("欢迎光临");
// private Button del = new Button("请慢走");
// private Bank bank = new Bank();
// private Hypermarket
