面试题15:Executors 提供的常用线程池有哪些?拒绝策略有哪些?

2023-05-09 21:35:43 浏览数 (1)

【Executors提供的常用线程池】

如下所示:

  • newCachedThreadPool

创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

  • newFixedThreadPool

创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。

  • newScheduledThreadPool

创建一个定长线程池,支持定时及周期性任务执行。

  • newSingleThreadScheduleExecutor

创建一个单线程执行程序,它可安排在给定延迟后运行命令或者定期地执行。(注意,如果因为在关闭前的执行期间出现失败而终止了此单个线程,那么如果需要,一个新线程会代替它执行后续的任务)。可保证顺序地执行各个任务,并且在任意给定的时间不会有多个线程是活动的。与其他等效的 newScheduledThreadPool(1) 不同,可保证无需重新配置此方法所返回的执行程序即可使用其他的线程。

  • newSingleThreadExecutor

创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。


【线程池的拒绝策略有如下四种:】

  • AbortPolicy

丢弃任务并抛出RejectedExecutionException异常。

  • DiscardPolicy

丢弃任务,但是不抛出异常。

  • DiscardOldestPolicy

丢弃队列中最前面的任务,然后重新尝试执行任务。

  • CallerRunsPolicy

由调用线程处理该任务。


【任务队列BlockingQueue 】

  • ArrayBlockingQueue

它是一个有界的阻塞队列,其内部实现是将对象放到一个数组里。一但初始化,大小就无法修改。

  • LinkedBlockingQueue

它内部以一个链式结构(链接节点)对其元素进行存储。可以指定元素上限,否则,上限则为Integer.MAX_VALUE。

  • DelayQueue

它对元素进行持有直到一个特定的延迟到期。注意:进入其中的元素必须实现Delayed接口。

  • PriorityBlockingQueue

它是一个无界的并发队列。无法向这个队列中插入null值。所有插入到这个队列中的元素必须实现Comparable接口。因此该队列中元素的排序就取决于你自己的Comparable实现。

  • SynchronousQueue

它是一个特殊的队列,它的内部同时只能够容纳单个元素。如果该队列已有一个元素的话,那么试图向队列中插入一个新元素的线程将会阻塞,直到另一个新线程将该元素从队列中抽走。同样的,如果队列为空,试图向队列中抽取一个元素的线程将会被阻塞,直到另一个线程向队列中插入了一条新的元素。因此,它其实不太像是一个队列,而更像是一个汇合点。

0 人点赞