线程及线程池学习

1 线程和进程的区别？

进程：进程指正在运行的程序。

线程：线程是进程中的一个执行单元，负责当前进程中程序的执行，一个进程中至少有一个线程。同一个进程中的多个线程之间可以并发的执行。

2 创建线程有哪几种方式？

创建线程有三种方式：

继承 Thread 重写 run 方法；

实现 Runnable 接口；

实现 Callable 接口。

3 runnable和callable的区别

3.1相同点

都是接口

都可以编写多线程程序

都采用Thread.start()启动线程

3.2不同点

Runnable没有返回值；Callable可以返回执行结果，是个泛型，和Future、

FutureTask配合可以用来获取异步执行的结果

Callable接口的call()方法允许抛出异常；Runnable的run()方法异常只能在内部消化，不能往上继续抛

注：Callalbe接口支持返回执行结果，需要调用FutureTask.get()得到，此方法会阻塞主进程的继续往下执行，如果不调用不会阻塞。

4 线程同步的方式

线程同步的方式有两种：

• 方式1：同步代码块

• 方式2：同步方法

同步代码块: 在代码块声明上 加上synchronized

synchronized (锁对象) {

可能会产生线程安全问题的代码

}

同步方法：在方法声明上加上synchronized

5 线程池

线程池，主要是管理线程，具有如下的优势：

（1）降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗。

（2）提高响应速度。当任务到达时，任务可以不需要等到线程创建就能立即执行。

（3）提高线程的可管理性。线程是稀缺资源，如果无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控。

5.1 线程池的七大参数

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {//...
}

这 7 个参数分别是：

corePoolSize：核心线程数。是指线程池中长期存活的线程数

maximumPoolSize：最大线程数。线程池允许创建的最大线程数量，当线程池的任务队列满了之后，可以创建的最大线程数。

keepAliveTime：空闲线程存活时间。空闲线程存活时间，当线程池中没有任务时，会销毁一些线程，销毁的线程数=maximumPoolSize（最大线程数）-corePoolSize（核心线程数）。

TimeUnit：时间单位。空闲线程存活时间的描述单位，

BlockingQueue：线程池任务队列。线程池存放任务的队列，用来存储线程池的所有待执行任务。

ThreadFactory：创建线程的工厂。线程池创建线程时调用的工厂方法，通过此方法可以设置线程的优先级、线程命名规则以及线程类型（用户线程还是守护线程）等。

RejectedExecutionHandler：拒绝策略。当线程池的任务超出线程池队列可以存储的最大值之后，执行的策略。

默认的拒绝策略有以下 4 种：

• AbortPolicy：拒绝并抛出异常。

• CallerRunsPolicy：使用当前调用的线程来执行此任务。

• DiscardOldestPolicy：抛弃队列头部（最旧）的一个任务，并执行当前任务。

• DiscardPolicy：忽略并抛弃当前任务。

线程池的默认策略是 AbortPolicy 拒绝并抛出异常。

6 案例

一 创建线程池

package com.yty.system.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;@Configuration
public class ExecutorConfig {@Bean("taskExecutor")public Executor taskExecutor() {ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();//设置线程池参数信息// 核心线程数taskExecutor.setCorePoolSize(3);// 最大线程数taskExecutor.setMaxPoolSize(4);// 线程队列数量taskExecutor.setQueueCapacity(2);// 空闲线程存活时间（秒）taskExecutor.setKeepAliveSeconds(60);// 线程名称前缀taskExecutor.setThreadNamePrefix("myExecutor--");// 线程执行完关闭taskExecutor.setWaitForTasksToCompleteOnShutdown(true);taskExecutor.setAwaitTerminationSeconds(60);// 修改拒绝策略为使用当前线程执行taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//初始化线程池taskExecutor.initialize();return taskExecutor;}}

二 使用

import com.yty.system.entity.AccountInfo;
import com.yty.system.entity.vo.R;
import io.swagger.annotations.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.bind.annotation.*;import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;/*** <p>*  前端控制器* </p>** @author yty* @since 2022-06-12*/
@RestController
@RequestMapping("/user")
@Api(tags = "用户管理API")
public class UserController {@Resourceprivate TaskExecutor taskExecutor;@GetMapping("listAsync")public R listAsync(int a) {long start = System.currentTimeMillis();CompletableFuture[] cf = new CompletableFuture[a];for (int i = 0; i < a; i++) {int finalI = i;cf[i] = CompletableFuture.runAsync(() -> {getA(finalI);}, taskExecutor);}// 是否执行完毕CompletableFuture.allOf(cf).join();long end = System.currentTimeMillis();String s = "总共耗时" + (end - start) + "毫秒";System.out.println(s);return R.ok(s);}private void getA(int i) {try {System.out.println("---------" + i);Thread.sleep(1000L);} catch (Exception e) {e.printStackTrace();}}}