1. import java.util.ArrayList;
   
2. import java.util.List;
   
3. import java.util.Random;
   
4. import java.util.concurrent.Executors;
   
5. import java.util.concurrent.ScheduledExecutorService;
   
6. import java.util.concurrent.TimeUnit;
   
7. 
   
8. 
   
9. public class Road {
   
10.         private List<String> vechicles = new ArrayList<String>();
    
11.         private String name;
    
12.         Road(String name){
    
13.                 this.name = name;
    
14.                 ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
    
15.                 pool.execute(new Runnable(){
    
16.                         public void run(){
    
17.                                 for(int i=1;i<1000;i++){
    
18.                                         try {
    
19.                                                 Thread.sleep((new Random().nextInt(10)+1)*1000);
    
20.                                         } catch (InterruptedException e) {
    
21.                                                 
    
22.                                                 e.printStackTrace();
    
23.                                         }
    
24.                                         vechicles.add(Road.this.name+"_"+i);
    
25.                                 }
    
26.                         }
    
27.                 });
    
28.                 ScheduledExecutorService timer = Executors.newScheduledThreadPool(1);
    
29.                 timer.scheduleAtFixedRate(
    
30.                                 new Runnable(){
    
31.                                         public void run(){
    
32.                                                 Lamp currentLamp = Lamp.valueOf(Road.this.name);
    
33.                                                 if(currentLamp.isLighted()){
    
34.                                                         System.out.println(vechicles.remove(0)+" is traversing.....!");
    
35.                                                 }
    
36.                                         }
    
37.                                 },
    
38.                                 1,
    
39.                                 1,
    
40.                                 TimeUnit.SECONDS
    
41.                                 );
    
42. 
    
43.         }
    
44. }
    

复制代码

1. 
   
2. public enum Lamp {
   
3.         S2N("N2S","S2W",false),S2W("N2E","E2W",false),E2W("W2E","E2S",false),E2S("W2N","S2N",false),
   
4.         N2S(null,null,false),N2E(null,null,false),W2E(null,null,false),W2N(null,null,false),
   
5.         S2E(null,null,true),E2N(null,null,true),N2W(null,null,true),W2S(null,null,true);
   
6.         
   
7.         private Lamp(String opposite,String next,boolean lighted){
   
8.                 this.opposite = opposite;
   
9.                 this.next = next;
   
10.                 this.lighted = lighted;
    
11.         }
    
12.         private boolean lighted;
    
13.         private String opposite;
    
14.         private String next;
    
15.         public boolean isLighted(){
    
16.                 return lighted;
    
17.                
    
18.         }
    
19.         public void light(){
    
20.                 this.lighted = true;
    
21.                 if(opposite!=null)
    
22.                         Lamp.valueOf(opposite).light();
    
23.                 System.out.println(name()+" lamp is green 一共有6个方向能看到汽车通过");
    
24. 
    
25.         }
    
26.         public Lamp balckOut(){
    
27.                 this.lighted = false;
    
28.                 if(opposite!=null){
    
29.                         Lamp.valueOf(opposite).balckOut();
    
30.                 }
    
31.                
    
32.                 Lamp nextLamp = null;
    
33.                
    
34.                 if(next!=null){
    
35.                         nextLamp = Lamp.valueOf(next);
    
36.                         System.out.println("绿灯从"+name()+" 切换为------>"+next);
    
37.                         nextLamp.light();
    
38.                 }
    
39.                 return nextLamp;
    
40.         }
    
41.         
    
42. }
    

复制代码

1. import java.util.concurrent.Executors;
   
2. import java.util.concurrent.ScheduledExecutorService;
   
3. import java.util.concurrent.TimeUnit;
   
4. 
   
5. 
   
6. public class LampController {
   
7.         private Lamp currentLamp;
   
8.         
   
9.         public LampController(){
   
10.                 currentLamp = currentLamp.S2N;
    
11.                 currentLamp.light();
    
12.                
    
13.                 ScheduledExecutorService timer = Executors.newScheduledThreadPool(1);
    
14.                 timer.scheduleAtFixedRate(
    
15.                                 new Runnable(){
    
16.                                         public void run(){
    
17.                                                 currentLamp = currentLamp.balckOut();
    
18.                                         }
    
19.                                 },
    
20.                                 10,
    
21.                                 10,
    
22.                                 TimeUnit.SECONDS
    
23.                                 );
    
24.         }
    
25. }
    

复制代码

1. 
   
2. public class MainClass {
   
3. 
   
4.         /**
   
5.          * @param args
   
6.          */
   
7.         public static void main(String[] args) {
   
8.                 String[] directions = {"S2N","S2W","E2S","N2S","N2E","W2E","W2N","S2E","E2N","N2W","W2S"};
   
9.                 for(int i=0;i<directions.length;i++){
   
10.                         new Road(directions[i]);
    
11.                 }
    
12.                 new LampController();
    
13.         }
    
14. 
    
15. }
    

复制代码

多添加注释；在road（）中添加System.out.print("！")输出语句看哪句没有执行到；