我有问题请教:
我在某个网站见到了线程池的例子。有所获得，也有所迷惑。
有一些内容很糊涂。所以请大家多多发表关于这方面的看法。帮助我从例子的细节中学习更多。

我自认为明白和不明白的都在代码注释中标上，如果我的认识有偏差，也请指正。
如果你有更好更易明白的讲解，或例子也请分享下吧。
先谢谢大家。
用例

一个厕所有3个坑,人们不停的进厕所做enen的事情.排量随机,蹲坑时间随机.  厕所的容量(capacity)为100, 当厕所的排量(volume)超过容量的时候, 通知清洁工来清洁. 清洁过程中不能再放新人进来. 厕所每天只服务100个人,然后停业.

本例中有4个类:

ThreadPool - main函数入口类.

Toilet - 厕所, 它使用一个具有3个线程处理能力的线程池来表达3个坑(holes)的概念.

People - 人, 排队上厕所

Cleaner - 清洁工, 清扫厕所

1. 
   
2. 
   
3. import java.util.Random;
   
4. import java.util.concurrent.ExecutorService;
   
5. import java.util.concurrent.Executors;
   
6. 
   
7. public class ThreadPoolTest {
   
8.    
   
9.     public static void main(String[] args) {
   
10.          ThreadPoolTest().test();//?为什么不可 test();
    
11.     }
    
12.    
    
13.     private void test() {
    
14.         Toilet toilet = new Toilet();
    
15.         
    
16.         boolean allowed = true;
    
17.         for (int i=0; allowed; i++) {//!循环的判断条件可以这样用。
    
18.             People p = new People(i+"", toilet);//i+""(String类)
    
19.             allowed = toilet.allowIn(p);
    
20.         }
    
21.     }
    
22.    
    
23.     private class Toilet {
    
24.         private volatile boolean cleaning = false;//？volatile的关键字在这里的作用是什么？
    
25.         private volatile int volume=0;
    
26.         private final int CAPACITY = 100;
    
27.         private volatile int peopleIn = 0;
    
28.         private volatile int count = 0;
    
29.         private Cleaner cleaner;
    
30.         // 3 holes in his toilet.
    
31.         private ExecutorService holes = Executors.newFixedThreadPool(3);
    
32.         
    
33.         private Toilet() {
    
34.             this.cleaner = new Cleaner(this);//？这里面的两个this所指是什么？
    
35.         }
    
36.         private synchronized boolean allowIn(Runnable people) {
    
37.             // If toilet is cleaning or 3 holes are taken, wait.
    
38.             while (this.cleaning == true || this.peopleIn >= 3 ) {
    
39.                 try {
    
40.                     this.wait();//？会不会造成死锁？
    
41.                 } catch (InterruptedException e) {
    
42.                     e.printStackTrace();
    
43.                 }
    
44.             }
    
45.             
    
46.             // Only serves 100 people one day.
    
47.             if (count > 100) {
    
48.                 this.holes.shutdown();//!哦，当人数大于100人，线程池关闭了。
    
49.                 return false;//！返回假，不准有人进入厕所了。
    
50.             } else {
    
51.                 this.peopleIn(((People)people).name);
    
52.                 holes.submit(people);//线程池接收一个人将分配一个线程给这个人。（即分一个坑给他，然后它执行它的事。）
    
53.                 return true;
    
54.             }
    
55.         }
    
56.         
    
57.         private synchronized void enEn(String name, int v) {
    
58.             this.volume += v;
    
59.             System.out.println("People["+name+"] put in ["+v+"]. Toilet volume increases to ["+volume+"]");
    
60.             
    
61.             // If the volume exceeds capacity, notify cleaner to clean.
    
62.             if (this.volume > this.CAPACITY) {
    
63.                 this.notifyCleaner();
    
64.             }
    
65.         }
    
66. 
    
67.         private void notifyCleaner() {
    
68.             if (this.cleaning == false) {
    
69.                 System.out.println("Toilet volume full with ["+volume+"]. Notify cleaner.");
    
70.                 holes.submit(cleaner);//?是清洁整个厕所，还是一个坑位？
    
71.             }
    
72.         }
    
73.         
    
74.         private synchronized void peopleIn(String name) {
    
75.             System.out.println("People["+name+"] comes in.");
    
76.             this.peopleIn ++;
    
77.             this.count++;
    
78.         }
    
79.         
    
80.         private synchronized void peopleOut(String name) {
    
81.             System.out.println("People["+name+"] comes out.");
    
82.             this.peopleIn --;//里面的人出来了，通知一下人，即唤醒wait();
    
83.             this.notifyAll();
    
84.         }
    
85.         public synchronized void cleaning() {
    
86.             this.cleaning = true;
    
87.             
    
88.         }
    
89.         public synchronized void cleaned() {
    
90.             this.cleaning = false;
    
91.             this.notifyAll();//！哦，被清洁后，唤醒wait()线程。
    
92.         }
    
93.     }
    
94.    
    
95.     // One toilet cleaner.
    
96.     private class Cleaner implements Runnable {
    
97.         private Toilet toilet;
    
98.         private Cleaner(Toilet t) {
    
99.             this.toilet = t;
    
100.         }
     
101. 
     
102.         @Override
     
103.         public void run() {
     
104.             toilet.cleaning();
     
105.             System.out.println("Toilet Cleaning...");
     
106.             try {
     
107.                 Thread.sleep(2000);
     
108.             } catch (InterruptedException e) {
     
109.                 e.printStackTrace();
     
110.             }
     
111.             this.toilet.volume = 0;
     
112.             System.out.println("Toilet Clean done.");
     
113.             toilet.cleaning = false;
     
114.             toilet.cleaned();
     
115.         }
     
116.     }
     
117.    
     
118.     private class People implements Runnable {
     
119.         private Toilet toilet;
     
120.         private String name;
     
121.         private People(String name, Toilet t) {
     
122.             this.toilet = t;
     
123.             this.name = name;
     
124.         }
     
125. 
     
126.         @Override
     
127.         public void run() {
     
128.             System.out.println("People["+name+"] is en en en...");
     
129.             try {
     
130.                 Thread.sleep(new Random().nextInt(500));
     
131.             } catch (InterruptedException e) {
     
132.                 e.printStackTrace();
     
133.             }
     
134.             //厕所统计：谁，拉了多少？然后把人放出来。
     
135.             toilet.enEn(name, new Random().nextInt(11));
     
136.             toilet.peopleOut(name);
     
137.         }
     
138.         
     
139.     }
     
140. 
     
141. }
     

复制代码

我有问题请教:
我在某个网站见到了线程池的例子。有所获得，也有所迷惑。
有一些内容很糊涂。所以请大家多多发表关于这方面的看法。帮助我从例子的细节中学习更多。

我自认为明白和不明白的都在代码注释中标上，如果我的认识有偏差，也请指正。
如果你有更好更易明白的讲解，或例子也请分享下吧。
先谢谢大家。
用例

一个厕所有3个坑,人们不停的进厕所做enen的事情.排量随机,蹲坑时间随机.  厕所的容量(capacity)为100, 当厕所的排量(volume)超过容量的时候, 通知清洁工来清洁. 清洁过程中不能再放新人进来. 厕所每天只服务100个人,然后停业.

本例中有4个类:

ThreadPool - main函数入口类.

Toilet - 厕所, 它使用一个具有3个线程处理能力的线程池来表达3个坑(holes)的概念.

People - 人, 排队上厕所

Cleaner - 清洁工, 清扫厕所

1. 
   
2. 
   
3. import java.util.Random;
   
4. import java.util.concurrent.ExecutorService;
   
5. import java.util.concurrent.Executors;
   
6. 
   
7. public class ThreadPoolTest {
   
8.    
   
9.     public static void main(String[] args) {
   
10.          ThreadPoolTest().test();//?为什么不可 test();
    
11.     }
    
12.    
    
13.     private void test() {
    
14.         Toilet toilet = new Toilet();
    
15.         
    
16.         boolean allowed = true;
    
17.         for (int i=0; allowed; i++) {//!循环的判断条件可以这样用。
    
18.             People p = new People(i+"", toilet);//i+""(String类)
    
19.             allowed = toilet.allowIn(p);
    
20.         }
    
21.     }
    
22.    
    
23.     private class Toilet {
    
24.         private volatile boolean cleaning = false;//？volatile的关键字在这里的作用是什么？
    
25.         private volatile int volume=0;
    
26.         private final int CAPACITY = 100;
    
27.         private volatile int peopleIn = 0;
    
28.         private volatile int count = 0;
    
29.         private Cleaner cleaner;
    
30.         // 3 holes in his toilet.
    
31.         private ExecutorService holes = Executors.newFixedThreadPool(3);
    
32.         
    
33.         private Toilet() {
    
34.             this.cleaner = new Cleaner(this);//？这里面的两个this所指是什么？
    
35.         }
    
36.         private synchronized boolean allowIn(Runnable people) {
    
37.             // If toilet is cleaning or 3 holes are taken, wait.
    
38.             while (this.cleaning == true || this.peopleIn >= 3 ) {
    
39.                 try {
    
40.                     this.wait();//？会不会造成死锁？
    
41.                 } catch (InterruptedException e) {
    
42.                     e.printStackTrace();
    
43.                 }
    
44.             }
    
45.             
    
46.             // Only serves 100 people one day.
    
47.             if (count > 100) {
    
48.                 this.holes.shutdown();//!哦，当人数大于100人，线程池关闭了。
    
49.                 return false;//！返回假，不准有人进入厕所了。
    
50.             } else {
    
51.                 this.peopleIn(((People)people).name);
    
52.                 holes.submit(people);//线程池接收一个人将分配一个线程给这个人。（即分一个坑给他，然后它执行它的事。）
    
53.                 return true;
    
54.             }
    
55.         }
    
56.         
    
57.         private synchronized void enEn(String name, int v) {
    
58.             this.volume += v;
    
59.             System.out.println("People["+name+"] put in ["+v+"]. Toilet volume increases to ["+volume+"]");
    
60.             
    
61.             // If the volume exceeds capacity, notify cleaner to clean.
    
62.             if (this.volume > this.CAPACITY) {
    
63.                 this.notifyCleaner();
    
64.             }
    
65.         }
    
66. 
    
67.         private void notifyCleaner() {
    
68.             if (this.cleaning == false) {
    
69.                 System.out.println("Toilet volume full with ["+volume+"]. Notify cleaner.");
    
70.                 holes.submit(cleaner);//?是清洁整个厕所，还是一个坑位？
    
71.             }
    
72.         }
    
73.         
    
74.         private synchronized void peopleIn(String name) {
    
75.             System.out.println("People["+name+"] comes in.");
    
76.             this.peopleIn ++;
    
77.             this.count++;
    
78.         }
    
79.         
    
80.         private synchronized void peopleOut(String name) {
    
81.             System.out.println("People["+name+"] comes out.");
    
82.             this.peopleIn --;//里面的人出来了，通知一下人，即唤醒wait();
    
83.             this.notifyAll();
    
84.         }
    
85.         public synchronized void cleaning() {
    
86.             this.cleaning = true;
    
87.             
    
88.         }
    
89.         public synchronized void cleaned() {
    
90.             this.cleaning = false;
    
91.             this.notifyAll();//！哦，被清洁后，唤醒wait()线程。
    
92.         }
    
93.     }
    
94.    
    
95.     // One toilet cleaner.
    
96.     private class Cleaner implements Runnable {
    
97.         private Toilet toilet;
    
98.         private Cleaner(Toilet t) {
    
99.             this.toilet = t;
    
100.         }
     
101. 
     
102.         @Override
     
103.         public void run() {
     
104.             toilet.cleaning();
     
105.             System.out.println("Toilet Cleaning...");
     
106.             try {
     
107.                 Thread.sleep(2000);
     
108.             } catch (InterruptedException e) {
     
109.                 e.printStackTrace();
     
110.             }
     
111.             this.toilet.volume = 0;
     
112.             System.out.println("Toilet Clean done.");
     
113.             toilet.cleaning = false;
     
114.             toilet.cleaned();
     
115.         }
     
116.     }
     
117.    
     
118.     private class People implements Runnable {
     
119.         private Toilet toilet;
     
120.         private String name;
     
121.         private People(String name, Toilet t) {
     
122.             this.toilet = t;
     
123.             this.name = name;
     
124.         }
     
125. 
     
126.         @Override
     
127.         public void run() {
     
128.             System.out.println("People["+name+"] is en en en...");
     
129.             try {
     
130.                 Thread.sleep(new Random().nextInt(500));
     
131.             } catch (InterruptedException e) {
     
132.                 e.printStackTrace();
     
133.             }
     
134.             //厕所统计：谁，拉了多少？然后把人放出来。
     
135.             toilet.enEn(name, new Random().nextInt(11));
     
136.             toilet.peopleOut(name);
     
137.         }
     
138.         
     
139.     }
     
140. 
     
141. }
     

复制代码