[JAVA/JSP] 线程池的正确使用姿势

复制代码
class XXXPool{
  // 获取池化资源
  XXX acquire() {
  }
  // 释放池化资源
  void release(XXX x){
  }
}

复制代码
//采用一般意义上池化资源的设计方法
class ThreadPool{
  // 获取空闲线程
  Thread acquire() {
  }
  // 释放线程
  void release(Thread t){
  }
}
//期望的使用
ThreadPool pool；
Thread T1=pool.acquire();
//传入Runnable对象
T1.execute(()->{
  //具体业务逻辑
  ......
});

复制代码
//简化的线程池，仅用来说明工作原理
class MyThreadPool{
  //利用阻塞队列实现生产者-消费者模式
  BlockingQueue<Runnable> workQueue;
  //保存内部工作线程
  List<WorkerThread> threads
    = new ArrayList<>();
  // 构造方法
  MyThreadPool(int poolSize,
    BlockingQueue<Runnable> workQueue){
    this.workQueue = workQueue;
    // 创建工作线程
    for(int idx=0; idx<poolSize; idx++){
      WorkerThread work = new WorkerThread();
      work.start();
      threads.add(work);
    }
  }
  // 提交任务
  void execute(Runnable command){
    workQueue.put(command);
  }
  // 工作线程负责消费任务，并执行任务
  class WorkerThread extends Thread{
    public void run() {
      //循环取任务并执行
      while(true){ ①
        Runnable task = workQueue.take();
        task.run();
      }
    }
  }
}

/** 下面是使用示例 **/
// 创建有界阻塞队列
BlockingQueue<Runnable> workQueue =
  new LinkedBlockingQueue<>(2);
// 创建线程池
MyThreadPool pool = new MyThreadPool(
  10, workQueue);
// 提交任务
pool.execute(()->{
    System.out.println("hello");
});

复制代码
ThreadPoolExecutor(
  int corePoolSize,
  int maximumPoolSize,
  long keepAliveTime,
  TimeUnit unit,
  BlockingQueue<Runnable> workQueue,
  ThreadFactory threadFactory,
  RejectedExecutionHandler handler)

• corePoolSize：表示线程池所持有的最小线程数。有些项目可能很闲，但也不能将所有项目组成员都撤离，至少要留下corePoolSize个人守在岗位上。
• maximumPoolSize：表示线程池可创建的最大线程数。当项目繁忙时，需要增加成员，但也不能无限制地增加，最多增加到maximumPoolSize个人。当项目变得闲暇时，需要减少成员，最多将成员减至corePoolSize个人。
• keepAliveTime & unit：前面提到，项目根据忙闲来增减成员。在编程世界中，如何定义忙和闲呢？很简单，如果一个线程在一段时间内都没有执行任务，说明它处于闲置状态。而keepAliveTime和unit就用来定义这段时间的参数。也就是说，如果一个线程空闲了keepAliveTime & unit这么长时间，并且线程池的线程数超过了corePoolSize，那么该空闲线程就会被回收。
• workQueue：工作队列，与上面示例代码中的工作队列意义相同。
• threadFactory：通过该参数，你可以自定义如何创建线程。例如，你可以为线程指定一个有意义的名称。
• handler：通过该参数，你可以自定义任务的拒绝策略。如果线程池中所有的线程都在忙碌，且工作队列已满（前提是工作队列是有界队列），此时提交任务，线程池将会拒绝接收。至于拒绝策略，你可以通过handler参数来指定。ThreadPoolExecutor已经提供了以下四种策略：
• CallerRunsPolicy：提交任务的线程自行执行该任务。
• AbortPolicy：默认的拒绝策略，会抛出RejectedExecutionException异常。
• DiscardPolicy：直接丢弃任务，没有任何异常抛出。
• DiscardOldestPolicy：丢弃最老的任务，实际上是丢弃最早进入工作队列的任务，并将新任务加入工作队列。
  0 N+ A- }) v/ Q, g

复制代码
try {
  //业务逻辑
} catch (RuntimeException x) {
  //按需处理
} catch (Throwable x) {
  //按需处理
}