java 多线程和线程池

java web

一、创建线程

• 官方指定的两种创建方式
  

1. 继承 Thread 类

• 创建一个类，继承 Thread 类，重写 run() 方法

public class MyThread extends Thread {
    @Override
    public void run() {
        // 业务逻辑
    }
    /**
     * 模拟调用
     */
    public static void main(String[] args) {
        MyThread myThread = new MyThread();
        // 启动线程
        myThread.start();
    }
}

2. 实现 Runnable 接口

• 实现 Runnable 接口，实现 run() 方法

public class MyRunnable implements Runnable{
    @Override
    public void run() {
        // 业务逻辑
    }
    /**
     * 模拟调用
     */
    public static void main(String[] args) {
        // 吧 Runnable 实现类的实例作为参数实例化 Thread
        MyRunnable runnable = new MyRunnable();
        Thread thread = new Thread(runnable);
        // 启动线程
        thread.start();
    }
}

二、线程常用方法

1. start() 启动线程

Thread thread = new Thread();
thread.start();

2. join() 等待线程

• 用在 start() 后面

// 启动了某个线程
thread.start();
// 等待上面的线程结束后再往下执行
thread.join();

3. isInterrupted() 是否已中断

thread.isInterrupted();

4. currentThread() 查看当前线程信息

// 查看线程id
Thread.currentThread().getId()
// 查看线程名称
Thread.currentThread().getName()

5. sleep() 线程延时

// 方法一：延时 1000 毫秒
Thread.sleep(1000)
// 方法二：延时 1 秒
TimeUnit.SECONDS.sleep(1);

6. synchronized 同步锁

// 锁类
public class synchronized Demo {
    // 锁对象方法
    public synchronized test() {
        // 锁对象业务块
        synchronized(this){}
    }
    // 锁类方法
    public synchronized static test() {
        // 锁类业务块
        synchronized(Demo.class){}
    }
}

三、线程池

1. 通过 ThreadPoolExecutor 创建线程

/**
 * 创建线程池
 * @param int                           corePoolSize 核心线程数
 * @param int                           maximumPoolSize 最大线程数
 * @param long                          keepAliveTime 空闲线程存活时间
 * @param TimeUnit                      unit 时间单位
 * @param BlockingQueue<Runnable>       workQueue 任务队列
 * @param ThreadFactory                 threadFactory 线程创建的方式
 * @param RejectedExecutionHandler      handler 拒绝策略
 */
ThreadPoolExecutor pool = new ThreadPoolExecutor(5, 8, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5));
// 提交任务
pool.execute(() -> {
    // 任务逻辑
});

2. 通过 Executors 静态创建线程池

2.1 newSingleThreadExecutor 单线程的线程池

• 这个线程池只有一个线程在工作，也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束，那么会有一个新的线程来替代它。

Executors.newSingleThreadExecutor();

2.2 newFixedThreadExecutor 固定大小的线程池

• 每次提交一个任务就创建一个线程，直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变，如果某个线程因为执行异常而结束，那么线程池会补充一个新线程

Executors.newFixedThreadExecutor();

2.3 newCacheThreadExecutor 可缓存的线程池

• 如果线程池的大小超过了处理任务所需要的线程，那么就会回收部分空闲（60秒不执行任务）的线程，当任务数增加时，此线程池又可以智能的添加新线程来处理任务。此线程池不会对线程池大小做限制，线程池大小完全依赖于操作系统（或者说JVM）能够创建的最大线程大小

Executors.newCacheThreadExecutor();

2.4 newScheduleThreadExecutor 无限大的线程池

• 此线程池支持定时以及周期性执行任务的需求

Executors.newScheduleThreadExecutor();

3. 通过 ScheduledThreadPoolExecutor 创建线程

• 用来执行延时或周期性任务

// 创建大小为2的线程池
ScheduledExecutorService pool = new ScheduledThreadPoolExecutor(2);
// 5秒后执行的任务
pool.schedule(() -> {
    // 任务逻辑
}, 5, TimeUnit.SECONDS);
// 相隔2秒执行一次的任务
pool.schedule(() -> {
    // 任务逻辑
}, 0, 2, TimeUnit.SECONDS);

四、线程池常用方法

1. submit() | execute() 提交任务

• 提交一个可运行的任务执行，并返回一个表示该任务结果

2. shutdown() 停止线程池

• 阻止新来的任务提交，对已经提交了的任务不会产生任何影响。当已经提交的任务执行完后，它会将那些闲置的线程进行中断，这个过程是异步的

3. shutdownNow() 立即停止线程池

• 设置线程池的状态为STOP，然后尝试停止所有的正在执行或暂停任务的线程，并返回等待执行任务的列表

4. isShutdown() 是否正在关闭线程池

5. isTerminated() 是否已经关闭线程池

6. awaitTermination() 等待线程关闭