1. public class Road
   
2. {
   
3. 
   
4. private List<String> vechicles = new ArrayList<String>();
   
5. 
   
6. private String name = null;
   
7. 
   
8. public Road(String name)
   
9. {
   
10. 
    
11. this.name = name;
    
12. // 创建一个使用单个 worker 线程的 Executor，以无界队列方式来运行该线程。
    
13. ExecutorService pool = Executors.newSingleThreadExecutor();
    
14. pool.execute(new Runnable()
    
15. {
    
16. 
    
17. // 模拟到达路口的汽车
    
18. @Override
    
19. public void run()
    
20. {
    
21. 
    
22. for (int i = 1; i < 1000; i++)
    
23. {
    
24. try
    
25. {
    
26. Thread.sleep(new Random().nextInt(10) * 1000);// 随机函数，实现在一到十秒过来一个汽车
    
27. }
    
28. catch (InterruptedException e)
    
29. {
    
30. // TODO Auto-generated catch block
    
31. e.printStackTrace();
    
32. }
    
33. vechicles.add(Road.this.name + "——" + i);// 向容器中添加小汽车。
    
34. }
    
35. }
    
36. });
    
37. 
    
38. // 一个定时器，模拟灯亮以后汽车一个一个的开走。
    
39. ScheduledExecutorService timer = Executors.newScheduledThreadPool(1);
    
40. timer.scheduleAtFixedRate(new Runnable()
    
41. {
    
42. 
    
43. @Override
    
44. public void run()
    
45. {
    
46. 
    
47. if (vechicles.size() > 0)
    
48. {
    
49. boolean lighted = Lamp.valueOf(Road.this.name).isLighted();// 获取当前灯的状态。
    
50. if (lighted)
    
51. System.out.println(vechicles.remove(0) + "is traveling");// 将汽车从路口移走。
    
52. }
    
53. }
    
54. }, 1, 1, TimeUnit.SECONDS);
    
55. }
    
56. 
    
57. ｝
    
58. 
    

复制代码

这里面的是有三个线程在同时执行，会不会有可能定时器抢不到执行资格而不会让汽车移走呢？

1. public class Road
   
2. {
   
3. 
   
4. private List<String> vechicles = new ArrayList<String>();
   
5. 
   
6. private String name = null;
   
7. 
   
8. public Road(String name)
   
9. {
   
10. 
    
11. this.name = name;
    
12. // 创建一个使用单个 worker 线程的 Executor，以无界队列方式来运行该线程。
    
13. ExecutorService pool = Executors.newSingleThreadExecutor();
    
14. pool.execute(new Runnable()
    
15. {
    
16. 
    
17. // 模拟到达路口的汽车
    
18. @Override
    
19. public void run()
    
20. {
    
21. 
    
22. for (int i = 1; i < 1000; i++)
    
23. {
    
24. try
    
25. {
    
26. Thread.sleep(new Random().nextInt(10) * 1000);// 随机函数，实现在一到十秒过来一个汽车
    
27. }
    
28. catch (InterruptedException e)
    
29. {
    
30. // TODO Auto-generated catch block
    
31. e.printStackTrace();
    
32. }
    
33. vechicles.add(Road.this.name + "——" + i);// 向容器中添加小汽车。
    
34. }
    
35. }
    
36. });
    
37. 
    
38. // 一个定时器，模拟灯亮以后汽车一个一个的开走。
    
39. ScheduledExecutorService timer = Executors.newScheduledThreadPool(1);
    
40. timer.scheduleAtFixedRate(new Runnable()
    
41. {
    
42. 
    
43. @Override
    
44. public void run()
    
45. {
    
46. 
    
47. if (vechicles.size() > 0)
    
48. {
    
49. boolean lighted = Lamp.valueOf(Road.this.name).isLighted();// 获取当前灯的状态。
    
50. if (lighted)
    
51. System.out.println(vechicles.remove(0) + "is traveling");// 将汽车从路口移走。
    
52. }
    
53. }
    
54. }, 1, 1, TimeUnit.SECONDS);
    
55. }
    
56. 
    
57. ｝
    
58. 
    

复制代码

这里面的是有三个线程在同时执行，会不会有可能定时器抢不到执行资格而不会让汽车移走呢？