转载

Java手动配置线程池过程详解

线程池中，常见有涉及到的：

ExecutorService executorService = Executors.newSingleThreadExecutor();  ExecutorService executorService1 = Executors.newCachedThreadPool();  ExecutorService executorService2 = Executors.newFixedThreadPool(3);

关于Executors和ExecutorService从记忆上类似于Collections和List。

但是以上几种其实不建议使用。最好可以通过自己手动配置ThreadPoolExecutor的形式。

我先创建一个demo:

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
        2,
        5,
        1L,
        TimeUnit.SECONDS,
        new ArrayBlockingQueue<Runnable>(3),
        Executors.defaultThreadFactory(),
        new ThreadPoolExecutor.AbortPolicy()
    );

涉及7个参数,按顺序分别是

int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler

具体我首先需要结合参数解释下线程池的执行原理：

画了张图：

如果我用银行办理业务示例说明如下：

1、首先银行里面有两个柜台，这就是核心线程数(7大参数之一)。

2、然后随着客户的增加，可能这个两个柜台满了，然后就要请用户到等候区里面进行等待。这个等候区就是相当于阻塞队列(七大参数之一)。

3、然后紧接着客户越来越多，连阻塞队列都撑不住了，这个时候，就要请求，上面的领导进行多增加柜台的操作，这个时候，可能加了三个柜台,现在就有5个柜台了。这个时候最大的线程数(七大参数之一)就是5了。

4、但是这个时候可能客户又越来越多，这个时候新加的柜台也受不了，就要开始有拒绝策略了(七大参数之一)

5、然后过了一段时间，慢慢的，客户越来越少了，这个时候，发现渐渐的，柜台空余出来了。KeepAliveTime(七大参数之一，加上单位，合计两个参数)指当线程数大于核心线程数时，此为终止前多余的空闲线程等待新任务的最长时间。

6、还有一个参数是工厂，这个我们不做深入研究，直接用默认的工厂即可。

懂得原理以后，我们可以查看下，为什么最好不要直接用，比如：

Executors.newFixedThreadPool(3);

这个的主要原因就是这里面默认队列的最大值是Integer的最大值。

所以我们生产中需要自己配置线程池。因为默认队列的长度太长了，有可能会导致oom。就是内存炸掉了。

这个在阿里的编程思想里面也有说明这一点：

这边我们探讨下，拒绝策略。4种策略。就是所有柜台和等候区全部满了。会如何处理。

用非常easy的代码来过下，这块的内容：

1、AbortPolicy

import java.util.concurrent.*;

public class VolatileTest {
  public static void main(String[] args) throws Exception {
    ExecutorService executorService = new ThreadPoolExecutor(
        2,
        5,
        1L,
        TimeUnit.SECONDS,
        new ArrayBlockingQueue<Runnable>(3),
        Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy()
    );

    try {
      for (int i = 0; i < 9; i++) {
        executorService.execute(new Runnable() {
          @Override
          public void run() {
            System.out.println(Thread.currentThread().getName()+"/t"+"办理业务");
          }
        });
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
    }

  }
}

可以看到如果超出的话直接挂了，阻止正常运行。

2、CallerRunsPolicy

输出

发现有一个退回main线程，被main线程处理。即会把任务退回至调用者。

3、DiscardOldestPolicy

这个将会等待时间最久的任务丢掉。

4、DiscardPolicy

多出来的任务会全部丢掉。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

时间：2020-05-12

基于java线程池读取单个SQL数据库表

任务:基于线程池来操作MySQL,测试单台机器读写MySQL单表的效率. 思路:创建一个大小合适的线程池,让每个线程分别连接到数据库并进行读取输出操作. 连接到数据库 import java.sql.DriverManager; import java.sql.SQLException; import com.mysql.jdbc.Statement; public class TEXT { } class MySQLOpen { private Connection con = null; p

Java中Future、FutureTask原理以及与线程池的搭配使用

Java中的Future和Future通常和线程池搭配使用,用来获取线程池返回执行后的返回值.我们假设通过Executors工厂方法构建一个线程池es ,es要执行某个任务有两种方式,一种是执行 es.execute(runnable) ,这种情况是没有返回值的: 另外一种情况是执行 es.submit(runnale)或者 es.submit(callable) ,这种情况会返回一个Future的对象,然后调用Future的get()来获取返回值. Future public interfac

Java线程池运行状态监控实现解析

在实际开发过程中,在线程池使用过程中可能会遇到各方面的故障,如线程池阻塞,无法提交新任务等. 如果你想监控某一个线程池的执行状态,线程池执行类 ThreadPoolExecutor 也给出了相关的 API, 能实时获取线程池的当前活动线程数.正在排队中的线程数.已经执行完成的线程数.总线程数等. 总线程数 = 排队线程数 + 活动线程数 + 执行完成的线程数. 线程池使用示例: private static ExecutorService es = new ThreadPoolExecutor(

到底如何设置Java线程池的大小的方法示例

在我们日常业务开发过程中,或多或少都会用到并发的功能.那么在用到并发功能的过程中,就肯定会碰到下面这个问题并发线程池到底设置多大呢? 通常有点年纪的程序员或许都听说这样一个说法 (其中 N 代表 CPU 的个数) CPU 密集型应用,线程池大小设置为 N + 1 IO 密集型应用,线程池大小设置为 2N 这个说法到底是不是正确的呢? 其实这是极不正确的.那为什么呢? 首先我们从反面来看,假设这个说法是成立的,那我们在一台服务器上部署多少个服务都无所谓了.因为线程池的大小只能服务器的核数有关,所

java通过Callable和Future来接收线程池的执行结果

在Java的线程执行中,不管是直接继承Thread的方式,还是实现Runnable接口的方式,都不会获取到线程执行的返回结果.这样如果线程在执行过程中出现了错误,那么主线程也不会感知到.即使打印了日志,也不能立即抛出异常.事后查看日志才能发现出现了bug.而且到那时发生问题的代码点距离真正的问题点可能会相差很远.如果在线程池执行的过程中出现了bug能及时地抛出异常,那么这将会是一个很好的实现.解决上述问题的办法是使用Callable接口,其可以获取到线程的返回结果,通过Future的get方法来

java线程池实现批量下载文件

本文实例为大家分享了java线程池实现批量下载文件的具体代码,供大家参考,具体内容如下 1 创建线程池 package com.cheng.webb.thread; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.ThreadFactory; import java.util.concurrent.Thr

Java线程池的拒绝策略实现详解

一.简介 jdk1.5 版本新增了JUC并发编程包,大大的简化了传统的多线程开发. Java线程池,是典型的池化思想的产物,类似的还有数据库的连接池.redis的连接池等.池化思想,就是在初始的时候去申请资源,创建一批可使用的连接,这样在使用的时候,就不必再进行创建连接信息的开销了.举个生活中鲜明的例子,在去著名洋快餐某基或者某劳的时候,配餐人员是字节从一个中间的保温箱里面直接取,然后打包就好了.不用再临时的来了一个单子,又要去拿原材料,又要去进行加工.效率明显的就是提高了很多. 既然是池子,那

Java线程池用法实战案例分析

本文实例讲述了Java线程池用法.分享给大家供大家参考,具体如下: 一使用newSingleThreadExecutor创建一个只包含一个线程的线程池 1 代码 import java.util.concurrent.*; public class executorDemo { public static void main( String[] args ) { ExecutorService executor = Executors.newSingleThreadExecutor(); ex

Java super关键字用法实战案例分析

本文实例讲述了Java super关键字用法.分享给大家供大家参考,具体如下: 一点睛如果子类继承了父类的数据成员,这时就需要调用父类的有参构造方法,来初始化来自父类的数据成员,这时就需要显示的调用父类中的有参构造方法super(参数1,参数2). 二实战--super调用父类中的构造方法 1 代码 class Person { String name; int age; public Person( String name, int age ) // 父类的构造方法 { this.nam

四种Java线程池用法解析

本文为大家分析四种Java线程池用法,供大家参考,具体内容如下 1.new Thread的弊端执行一个异步任务你还只是如下new Thread吗? new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub } } ).start(); 那你就out太多了,new Thread的弊端如下: a. 每次new Thread新建对象性能差. b. 线程缺乏统一管理,可能无限

Java线程池的应用实例分析

本文实例讲述了Java线程池的应用.分享给大家供大家参考,具体如下: 一使用Future与Callable来计算斐波那契数列 1 代码 import java.util.concurrent.*; public class FutureCallableDemo { static long fibonacci(long n) { if (n == 1 ||n == 2) return 1; else return fibonacci(n - 1) + fibonacci(n - 2); } pu

Java static方法用法实战案例总结

本文实例讲述了Java static方法用法.分享给大家供大家参考,具体如下: 一点睛用static可以声明一个静态属性变量,其实,也可以用来声明方法,用它声明方法时也称为"类方法".使用static定义的方法可以由类名直接调用. static的main方法可以接收一个String类型的数组参数,该数组中保存执行Java命令时传递给所运行的类的参数.格式如下: java 类名称参数1 参数2 参数3 二实战--静态方法的声明 1 代码 class Person { String

Java System类用法实战案例

本文实例讲述了Java System类用法.分享给大家供大家参考,具体如下: 一使用System类访问系统属性 1 代码 import java.util.Map; public class SystemClassDemo { public static void main(String[] args) { Map<String, String> env = System.getenv(); // 获得系统的环境变量 for (String name : env.keySet()) { Sy

Java中包的概念和用法实战案例分析

本文实例讲述了Java中包的概念和用法.分享给大家供大家参考,具体如下: 一点睛 1 package的声明方法: package package名称[.package名称2.package名称3]; 2 包的导入方法如下: import package 包名称.类名称 3 如果一个项目之中有几百个类,一个个导入会比较麻烦,为了方便导入,可以使用"包名.*"的形式完成,例如: import java.io.*; 这里的"*"是通配符,表示该"包名"

Java ThreadLocal类应用实战案例分析

本文实例讲述了Java ThreadLocal类应用.分享给大家供大家参考,具体如下: 一点睛 ThreadLocal,是Thread Local Variable(线程局部变量)的意思,也许将它命名为ThreadLocalVar更加合适. 线程局部变量(ThreadLocal)其实的功用非常简单,就是为每一个使用该变量的线程都提供一个变量值的副本,使每一个线程都可以独立地改变自己的副本,而不会和其它线程的副本冲突.从线程的角度看,就好像每一个线程都完全拥有该变量. ThreadLocal类的

详解Java线程池和Executor原理的分析

详解Java线程池和Executor原理的分析线程池作用与基本知识在开始之前,我们先来讨论下"线程池"这个概念."线程池",顾名思义就是一个线程缓存.它是一个或者多个线程的集合,用户可以把需要执行的任务简单地扔给线程池,而不用过多的纠结与执行的细节.那么线程池有哪些作用?或者说与直接用Thread相比,有什么优势?我简单总结了以下几点: 减小线程创建和销毁带来的消耗对于Java Thread的实现,我在前面的一篇blog中进行了分析.Java Thread与内

Java线程等待用法实例分析

本文实例讲述了Java线程等待用法.分享给大家供大家参考,具体如下: 线程等待 public class Hello { public static void main(String[] args) { A a = new A(); new Thread(new MyRun(a)).start(); new Thread(new MyRun1(a)).start(); } } class MyRun implements Runnable { private A a; public MyRun(

原文 https://www.zhangshengrong.com/p/Z9a239bzNV/

正文到此结束