java:线程池

目录

什么是线程池？

不使用线程池的问题

创建线程池

如何创建线程池对象？

方式一：使用ExecutorService的实现类ThreadPoolExecutor自创建一个线程池对象。

什么时候开始创建临时线程？

什么时候拒绝策略？

方式二：通过Executors创建线程池。

Executors可能存在的陷阱

什么是线程池？

答：线程池就是一个可以复用线程的技术。

不使用线程池的问题

答：用户每次发起一个请求，后台就需要创建一个新线程来处理，下次新任务来了肯定又要创建新线程的开销是很大的，并且请求过多时，肯定会产生大量的线程出来，这样会影响系统的性能。

创建线程池

JDK5.0起提供了代表线程池的接口：ExecutorService.

如何创建线程池对象？

方式一：使用ExecutorService的实现类ThreadPoolExecutor自创建一个线程池对象。

方式二：使用Executors（线程池的工具类）调用方法返回不同特点的线程池对象。（不推荐，后面会说）

方式一：使用ExecutorService的实现类ThreadPoolExecutor自创建一个线程池对象。

public ThreadPoolExecutor(int corePoolSize,

int maximumPoolSize,

long keepaliveTime,

TimeUnit unit,

BlockingQueue<Runnable>workQueue,

ThreadFactory thread Factory,

RejectedExecutionHandler)

使用指定的初始化参数创建一个新的线程池对象。

参数一：corePooLSize:指定线程池的核心线程的数量。

参数二：maximumPoolSize:指定线程池的最大线程数量。

参数三：keepAliveTime:指定临时线程的存活时间。

参数四：unit:指定临时线程存活或时间单位（秒,分，时，天）

参数五：workQueue:指定线程池的任务队列。

参数六：threadFactory:指定线程池的线程工厂。

参数七:handler:指定线程池的任务拒绝策略（线程都在忙，任务队列也满的时候，新任务就会拒绝）

package ExecutorServicedemo1;

import java.util.concurrent.*;


public class ExecutorServicedemo2 {
    public static void main(String[] args) {
        // 使用正确的构造函数签名创建线程池
        ExecutorService executorServices = new ThreadPoolExecutor(
                3, // 核心线程数
                5, // 最大线程数
                10, // 空闲线程存活时间
                TimeUnit.SECONDS, // 时间单位
                new ArrayBlockingQueue<>(3), // 任务队列
                Executors.defaultThreadFactory(), // 线程工厂
                new ThreadPoolExecutor.AbortPolicy() // 拒绝策略
        );

             MyRunnable myRunnable = new MyRunnable();
             executorServices.execute(myRunnable);
             executorServices.execute(myRunnable);
             executorServices.execute(myRunnable);
               Future<String> f1 = executorServices.submit(new MyCallable(10));
             try {
                 System.out.println(f1.get());
             }
             catch (Exception e) {
                 e.printStackTrace();
             }

    }
}

package ExecutorServicedemo1;

public class MyRunnable implements Runnable{
    @Override
    public void run()
    {
        for(int i = 0; i < 10; i++)
        {
            System.out.println(Thread.currentThread().getName() + ": " + i);
        }
    }
}

package ExecutorServicedemo1;

import java.util.concurrent.Callable;

public class MyCallable implements Callable<String> {
    private int n;

    public MyCallable(int n) {
        this.n = n;
    }
    public String call() throws Exception {
        int sum = 0;
        for (int i = 0; i < n; i++) {
            sum += i;
        }
        return Thread.currentThread().getName() + ":" + sum;
    }
}

什么时候开始创建临时线程？

新任务提交时发现核心线程都在忙，任务队列也满了，并且还可以创建临时线程，此时才会创建线程。

什么时候拒绝策略？

核心线程和临时线程都在忙，任务队列也满了，新的任务过来的时候才会开始拒绝任务。

通过Executors创建线程池

是一个线程池的工具类，提供了很多静态方法用来返回不同特点的线程池对象。

方式二：通过Executors创建线程池。

 ExecutorService a= Executors.newFixedThreadPool(3);

Executors可能存在的陷阱

大型并发系环境中使用Executors去创建，如果不注意，可能会出现系统风险，而是通过ThreadPoolExecutor。