java虚拟机多线程进阶篇总结

ExecutorService pool = Executors.newFixedThreadPool(3);
pool.execute(new RunnableImpl("玩游戏"));

 public void execute(Runnable command) {
  if (command == null)
   throw new NullPointerException();
   int c = ctl.get();
　　　　
//workCountOf（c）表示当前线程池中线程的数量；这里进行一个判断，当线程池中线程数目小于核心池子数目时，
　　就调用addWorker（）方法将我们的任务添加进去，等下可以看到addWorker（）方法内部其实就是创建线程并处理请求，
　　就类似new Thread（xxx）.start()这种方式
 　　　　if (workerCountOf(c) < corePoolSize) {
   if (addWorker(command, true))
    return;
   c = ctl.get();
  }

//如果当前线程数目大于核心线程并且任务放入一个队列成功，内部还会再次进行线程池状态判断，这里的&&用得比较精髓（短路作用），好好体会一下，
　　假如不是运行状态那就会执行remove方法 删除队列中的任务，如果是运行状态直接进入else if，这里的目的是线程池中已经关闭了，我们添加一个null任务
　　表示线程池不再处理任务  
　　　　if (isRunning(c) && workQueue.offer(command)) {
   int recheck = ctl.get();
   if (! isRunning(recheck) && remove(command))
    reject(command);
   else if (workerCountOf(recheck) == 0)
    addWorker(null, false);
  }

//能执行到这里，说明上面两个if中的条件都不满足，条件应该是：当前线程大于核心线程，并且向队列中添加任务失败，换句说说就是对列已经满了，装不下这么多任务
　　于是我们reject（）方法内部就是对这些多余的任务进行处理的一些策略，默认就是直接丢弃
  else if (!addWorker(command, false))
   reject(command);
 }

private boolean addWorker(Runnable firstTask, boolean core) {
  //这里删除很多的条件判断的代码
　　　　..........
　　　　
　　　　 boolean workerStarted = false;
  boolean workerAdded = false;
  Worker w = null;
  try {
   final ReentrantLock mainLock = this.mainLock;
   //注意下面这两行，其实就是将我们传进来的Runnable（）进行封装成Worker，在Worker构造器里面会new Thread（）并且保存起来
　　　　　　　这样做的一个好处就是直接将一个线程和一个Runnable进行绑定，我们随时可以从Worker中获取线程然后调用start（）方法就ok了
　　　　　　　w = new Worker(firstTask);
   final Thread t = w.thread;
   if (t != null) {
    mainLock.lock();
    try {
     //此处删除一些
　　　　　　　　　　　　.........
     if (rs < SHUTDOWN ||
      (rs == SHUTDOWN && firstTask == null)) {
      if (t.isAlive()) // precheck that t is startable
       throw new IllegalThreadStateException();

　　　　　　　　　　　　　　//由于会有很多个Worker，于是我们会创建HashSet<Worker> workers = new HashSet<Worker>()，用于保存所有的worker，后续直接遍历处理很方便
　　　　　　　　　　　　　　而且我们所说的线程池的本质就是这个workers，也就是一个HashSet
　　　　　　　　　　　　　　workers.add(w); 
　　　　　　　　　　　　　　int s = workers.size();
      if (s > largestPoolSize)
       largestPoolSize = s;
      workerAdded = true;
     }
    } finally {
     mainLock.unlock();
    }
　　　　　　　　　　//下面这个if语句中就是一个无限循环的去执行线程的start（）方法
    if (workerAdded) {
     t.start();
     workerStarted = true;
    }
   }
  }return workerStarted;
 }

Worker w = new Worker(firstTask);
final Thread t = w.thread;
........
t.start()

Worker w = new Worker(firstTask);//firstTask是我们传进去的实现了Runnable接口的类，但是Worker也实现了Runnable接口　

final Thread t = getThreadFactory().newThread(w

t.start()