为什么使用线程池，在什么情况下使用线程池，拒绝策略，核心线程数的选型

快来打我* 2022-12-06 12:59 74阅读 0赞

### 这里写目录标题 ###

*  线程池的场景
 *  池化技术
 *  线程池流程

# 线程池的场景 #

*  我当时调用连薪商户-服务商接口，该接口的目的是：
    
     *  在客户发薪成功的回调接口中，去调用连薪服务商回单下载接口，但是连薪的付款成功和下载之间有3-5秒的延迟，这里睡眠了5秒之后，开启线程池去下载回单。
 *  分布式锁：
    
     *  使用reds做分布式锁时，容易造成锁失效。
     *  假如使用setNx和Expire进行加锁，设置超时时间为10s，使用delete方法进行解锁。
     *  现有线程1和线程2访问下单接口，线城1完成任务耗时15S，在第10s秒已超时，锁失效，此时库存值还没有更新到Redis，但数据库库存减掉了。线程2在第10s时获得锁，并修改了Redis和mysql值，这就造成了超卖的异常。因而，当线程1获得Redis锁时，便开启线程池，每隔3秒去查看线程1是否持有锁，如果持有锁，则增加锁的延迟时间。

# 池化技术 #

说到线程池，很自然想到数据库连接池，他们都用到池化技术。以最少的serverSocket来完成尽量多的socket请求，从而更大限度的发挥CPU的性能，提高吞吐量。

我们都知道不论是hibernate也好，Mybatis也好，其内部使用的jdbc。Jdbc内部是基于TCP协议的socket通信，socket通信有两处阻塞，连接阻塞和读写阻塞。因而在在项目启动时，便创建了核心长连接数\[StandardSocketFactory\]，这样避免每次请求都建立连接的性能消耗，提高数据库访问的吞吐量。

连接池一般会有核心连接数、阻塞队列、最大线程数。

1.  核心连接数：一般是电脑或服务器的cpu数量，如果是Java代码，可以通过「Runtime.getRuntime().availableProcessors()」获取。
2.  最大线程数
    
     *  CPU密集型：n+1
     *  I/O密集型：2n+1

# 线程池流程 #

线程池也是池化一种，也有连接池的特性——以最少的线程，完成更多的任务。

如果客户端每个任务过来，就去创建一个线程去处理，那么势必会创建很多线程。

然而，java分为用户线程和内核线程，new Thread()是创建用户线程，thread.start()方法是创建内核线程。java通过start0()方法通过jvm地第三方语言去创建内核线程，因而，java创建线程的代价很高。如果处理不当，还是造成CPU飙升，因而，考虑到这个问题，便有了线程池，复用已有的线程。

当一个任务请求过来，首先使用workContOf方法，判断当前线程池中的线程数是否小于核心线程数，如果小于核心线程数，便去创建新的线程。将当前任务置为新线程的第一个任务，于是去调用runTask方法，在该方法中执行「firstTask.run()」，任务执行完毕后，gc回收当前任务。

如果队列中的任务已满，仍有新的任务进来。则判断线程数量是否达到最大线程的数量，如果没有达到最大线程的数量，那么就去创建一个新的线程，将当前任务置为新线程的第一个任务，于是去调用runTask方法，在该方法中执行「firstTask.run()」，任务执行完毕后，gc回收当前任务。

如果线程数量达到线程池中所能创建的最大线程的数量，便使用线程池地饱和拒绝策略。

<table> 
 <thead> 
  <tr> 
   <th>策略名称</th> 
   <th>策略目的</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>abortPolicy</td> 
   <td>默认策略，丢弃任务，并抛出拒绝异常。</td> 
  </tr> 
  <tr> 
   <td>discardOldestPolicy</td> 
   <td>丢弃队列里最近的一个任务并执行当前任务。</td> 
  </tr> 
  <tr> 
   <td>discardPolicy</td> 
   <td>不处理,丢弃掉。</td> 
  </tr> 
  <tr> 
   <td>runCallersPolicy</td> 
   <td>只用调用者所在的线程来执行任务。</td> 
  </tr> 
 </tbody> 
</table>

如果队列中的任务数小于队列数，而线程在指定时间内是空闲的，那么当前线程便被回收，但核心线程不会被回收，以便下次复用。