一种不同张孝祥老师视频中交通灯管理系统的实现 - 黑马程序员技术交流社区

public class Lampinfo {
//方向从北向南，从西向东
Route[] route = {Route.N2S,Route.W2E};
//数据结构怎么定义，代表不同的路况默认是北南方向绿，西东方向红
private Map<Route, Lamp> lampinfo = new HashMap<Route, Lamp>();

复制代码

package cn.itcast.mytraffic;
public enum Route {
//定义12个方向
//右转，四个方向，不需要看红绿灯
N2W,E2N,W2S,S2E,
//左转，直行需要看红绿灯
//当N-S和S-N方向通畅时
//N-S方向直行，左转,S-N方向直行，左转
N2S,N2E,S2N,S2W,
/*
* 当W-E方向和E-W方向通畅时
* W-E方向直行，左转，E-W方向直行，左转
*/
W2E,W2N,E2W,E2S;
//以上共12中行驶路线
//重新实现tostring方法，用来输出实际的路线信息
public String toString() {
switch (this) {
case N2W:
return "北向西，右转";
case E2N:
return "东向北，右转";
case W2S:
return "西向南，右转";
case S2E:
return "南向东，右转";
case N2S:
return "北向南，直行";
case N2E:
return "北向东，左转";
case S2N:
return "南向北，直行";
case S2W:
return "南向西，左转";
case W2E:
return "西到东，直行";
case W2N:
return "西到北，左转";
case E2W:
return "东到西，直行";
case E2S:
return "东到南，左转";
default:
System.out.println("出错啦!!");
break;
}
return null;
};
}

复制代码

package cn.itcast.mytraffic;
import java.util.LinkedList;
import java.util.Queue;
import java.util.Random;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class Road {
//N-S和S-N是绿灯的行驶车辆信息这里考虑用队列来实现，其好处是不用判断前面的车是否出去了，因为队列就是前端删除，后端插入。
//private List<Route> CarN2S = new ArrayList<Route>();
private Queue<Route> CarN2S = new LinkedList<>();
//W-E和E-W是绿灯的形式车辆信息
//private List<Route> CarW2E = new ArrayList<Route>();
private Queue<Route> CarW2E = new LinkedList<>();
//封装从N-S和S-N是绿灯时车辆所有可能的行驶方向
private Route[] routeN2S ={Route.N2S,Route.N2E,Route.S2N,Route.S2W,Route.N2W,Route.S2E,Route.W2S,Route.E2N};
//封装从W-E和E-W是绿等是车辆所有可能的形式方向
private Route[] routeW2E = {Route.W2E,Route.W2N,Route.E2N,Route.E2S,Route.E2W,Route.W2S,Route.S2E,Route.N2W};
//用队列的方式实现车的添加和减少
public Road(){
//从N-S方向先随机生成5辆车
for(int i=0;i<5;i++){
CarN2S.offer(routeN2S[new Random().nextInt(7)]);
}
//从W-E方向也随机生成5辆车
for(int i=0;i<5;i++){
CarW2E.offer(routeW2E[new Random().nextInt(7)]);
}
}
private void addCar(){
//每1秒路上增加1辆车
if(!CarN2S.offer(routeN2S[new Random().nextInt(7)])){
System.out.println("车辆增加异常！");
}
//每1秒路上增加一辆车
if(!CarW2E.offer(routeW2E[new Random().nextInt(7)])){
System.out.println("车辆增加异常！");
}
//System.out.println("进入addCar了");
}
public void Start(){
//创建一个可以调度线程池用来分别添加两个方向的车
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
//这么做线程应该发生了死锁？不是死锁，无法插入元素了，数组越界了，小bug找了好久。
addCar();
// System.out.println("从addCar出来了");
}
},
1,
2,
TimeUnit.SECONDS);
}
public Route getCarN2S() {
return CarN2S.poll();
}
public Route getCarW2E() {
return CarW2E.poll();
}
}

复制代码

package cn.itcast.mytraffic;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class TrafficControl {
/*private Lamp[] lamps={Lamp.RED,Lamp.GREEN};*/
private Road road;
private Lampinfo lampinfo;
public TrafficControl(Road road,Lampinfo lampinfo){
this.road = road;
this.lampinfo = lampinfo;
}
//根据灯的信息来调度不同路线上的车辆
public synchronized void schedule(){
//判断当前的红绿灯颜色
Map<Route, Lamp> lamp = lampinfo.getLampinfo();
//从南向北行驶的所有车辆应该获得该方向的灯的颜色
//绿灯，可以行驶
if(lamp.get(Route.N2S) == Lamp.GREEN){
//线程在这里面等待获得队列删除后返回的元素，程序在这里面发生了死锁？
Route carinfN2S= road.getCarN2S();
if(carinfN2S == null){
System.out.println("没车了！！");
}else {
System.out.println("从南向北方向畅通"+carinfN2S.toString() + "正在行驶");
}
}else if (lamp.get(Route.W2E) == Lamp.GREEN) {
//线程在这里面等待获得队列删除后返回的元素，程序在这里面发生了死锁？
Route carinfW2E = road.getCarW2E();
if(carinfW2E == null){
System.out.println("没车了！！");
}else{
System.out.println("从西向东方向畅通" + carinfW2E.toString() + "正在行驶");
}
}
}
public void Start(){
Executors.newScheduledThreadPool(1).scheduleAtFixedRate(
new Runnable() {
@Override
public void run() {
schedule();
}
},
2,
1,
TimeUnit.SECONDS);
}
}

复制代码

package cn.itcast.mytraffic;
public class StartMain {
public static void main(String[] args) {
Road road = new Road();
Lampinfo lampinfo = Lampinfo.newinstance();
TrafficControl trafficControl = new TrafficControl(road, lampinfo);
//开启交通灯
lampinfo.Start();
//路上开始不断的增加车辆
road.Start();
//开始调度
trafficControl.Start();
}
}

复制代码