黑马程序员技术交流社区

标题: 线程池，关于上厕所的问题。 [打印本页]
作者: 黄嵘才    时间: 2012-12-4 14:05
标题: 线程池，关于上厕所的问题。
我有问题请教:
我在某个网站见到了线程池的例子。有所获得，也有所迷惑。
有一些内容很糊涂。所以请大家多多发表关于这方面的看法。帮助我从例子的细节中学习更多。

我自认为明白和不明白的都在代码注释中标上，如果我的认识有偏差，也请指正。
如果你有更好更易明白的讲解，或例子也请分享下吧。
先谢谢大家。
用例
一个厕所有3个坑,人们不停的进厕所做enen的事情.排量随机,蹲坑时间随机.  厕所的容量(capacity)为100, 当厕所的排量(volume)超过容量的时候, 通知清洁工来清洁. 清洁过程中不能再放新人进来. 厕所每天只服务100个人,然后停业.
本例中有4个类:
ThreadPool - main函数入口类.
Toilet - 厕所, 它使用一个具有3个线程处理能力的线程池来表达3个坑(holes)的概念.
People - 人, 排队上厕所
Cleaner - 清洁工, 清扫厕所


  3. import java.util.Random;
  4. import java.util.concurrent.ExecutorService;
  5. import java.util.concurrent.Executors;

  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.         }

  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.         }

  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.         }

  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.     }

  141. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2