目录
多线程的创建
方式一:继承Thread类
方式二:实现Runnablel接口
方式三:JDK5.0新增Callable接口
Thread的常用方法
线程安全
线程同步
线程通信
线程池【重点】
定时器
补充知识:并发、并行
生命周期
什么是线程?
- 线程(Thread)是一个程序内部的一条执行路径。
- 启动程序执行之后,main方法的执行其实就是一条单独的执行路径。
- 程序中如果只有一条执行路径,那么这个程序就是单线程。
多线程是什么?
- 多线程是指从软硬件上实现多条执行流程的技术
- 消息通信、淘宝、京东系统都离不开多线程技术
多线程的创建
方式一:继承Thread类
Thread类
Java是通过java.lang.Thread类来代表线程。
按照面向对象的思想,Thread类应该提供了实现多线程的方式。
继承Thread类
- 定义一个子类MyThread继承线程类java.long.Thread,重写run()方法
- 创建一个MyThread类对象
- 调用线程对象的start()方法启动线程(启动后还是执行run方法)
优缺点:
- 优点:编程简单
- 缺点:线程类已经继承Thread,无法继承其他类,不利于扩展
1.为什么不直接调用run方法,而是调用start启动线程
- 直接调用run方法会当成普通方法执行,此时相当于还是方向陈执行。
- 只有调用start方法才是启动一个新的线程执行
2.把主线程放在子线程之前了
- 这样主线程一直是先跑完的,相当于是一个单线程的效果
方式二:实现Runnablel接口
多线程的实现方案二:实现Runnable接口
- 定义一个线程任务类MyRunnable实现Runnable接口,重写run()方法
- 创建MyRunnable任务对象
- 把MyRunnable任务对象交给Thread处理
- 调用线程对象的start()方法启用线程
构造器 | 说明 |
public Thread(String name) | 可以为当前线程指定名称 |
public Thread(Runnable target) | 封装Runnable对象成为线程对象 |
public Thread(Runnable target , String name) | 封装Runnable对象成为线程对象并指定线程名称 |
2.第二种方式的优缺点
- 优点:线程任务类只是实现了Runnable接口,可以继续继承和实现
- 缺点:如果线程有执行结果是不能返回的
方式三:JDK5.0新增Callable接口
- 多线程的实现方法三:利用Callable、Futuretask接口实现
- 得到任务对象
- 定义类实现Callable接口,重写call方法,封装要做的事情
- 用FutureTask把Callable对象封装成线程任务对象
- 把线程任务对象交给Thread处理
- 调用Thread的start方法启动线程,执行任务
- 线程执行完毕后,通过FutureTask的get方法去获取任务执行的处理
方法名称 | 说明 |
public FutureTask<>(Callable call) | 把Callable对象封装成FutureTask对象。 |
public V get()throws Exception | 获取线程执行call方法返回的结果 |
方式三的优缺点:
- 优点:线程任务类只是实现接口,可以继续继承类和实现接口,扩展性强。
- 可以子啊线程执行完毕之后去获取线程执行结果。
- 缺点:编码稍微复杂
Thread的常用方法
1.当有很多线程在执行的时候,我们应该怎么去区分这些线程呢?
此时需要使用Thread的常用Thread的方法:getName()、setName()、currentThread()deng
方法名称 | 说明 |
public Thread(String name) | 可以为当前线程指定名称 |
public Thread(Runnable target) | 封装Runnable对象成为线程对象 |
public Thread(Runnable target , String name) | 封装成Runnable对象成为线程对象,并指定线程名称 |
方法名称 | 说明 |
public static void sleep(long time) | 让当前线程休眠指定时间后再继续执行,单位为毫秒 |
方法名称 | 说明 |
public static void sleep(long time) | 让当前线程休眠指定时间后再继续执行,单位为毫秒 |
public void start() | 线程启动方法 |
public void run() | 线程任务方法 |
public static Thread currentThread(); | 返回对当前正在执行的线程对象的引用 |
String getName() | 获取当前线程的名称,默认线程名称是Thread-索引 |
void setName(String name) | 设置线程名称 |
线程安全
线程安全问题
- 多个线程同时操作同一个共享资源的时候可能会出现业务安全问题,称为线程安全问题。
线程安全问题出现的原因?
- 存在多线程并发
- 同时访问共享资源
- 存在修改共享资源
线程同步
如何才能保证线程安全?
- 让多个线程实现先后依次访问共享资源,这样就解决了安全问题
线程同步的核心思想
- 加锁,把共享资源进行上锁,每次只能一个线程进入访问完毕以后解锁,然后其他线程才能进来
同步代码块
- 作用:把出现线程安全问题的核心代码给上锁。
- 原理:每次只能一个线程进入,执行完毕后自动解锁,其他线程才可以进来执行。
synchronized(同步锁对象){操作共享资源的代码(核心代码)
}
锁对象要求
- 理论上:锁对象只要对于当前同时执行的线程来说是同一个对象即可
锁对象用任意唯一的对象好不好?
- 不好,会影响其他无关线程的执行
锁对象的规范要求
- 规范上:建议使用共享资源作为锁对象
- 对于实例方法建议使用this作为锁对象
- 对于静态方法建议使用字节码(类名.class)对象作为锁对象
同步代码块是如何实现线程安全的
- 对于出现问题的核心代码使用synchronized进行加锁
每次只能一个线程占锁进入访问
- 同步代码块的同步锁对象有什么要求
- 对于实例方法建议使用this作为锁对象
- 对于静态方法建议使用字节码(类名.class)对象作为锁对象
同步方法
- 作用:把出现线程安全问题的核心方法上锁
- 原理:每次只能一个线程进入,执行完毕以后自动解锁,其他线程才可以进来执行
修饰符 synchronized 返回值类型 方法名称(形参列表){操作共享资源代码
}
同步方法底层原理
- 同步方法底层也是隐式锁对象,只是锁的范围是整个方法代码。
- 如果方法是实例化,同步方法默认用this作为锁对象。但是代码要高度面向对象。
- 如果方法使用的是静态方法,同步方法默认用类名.class作为的锁对象。
Lock锁
- 为了更清晰的表达如何加锁和释放锁,JDK5以后提供了一个新的锁对象Lock,更加灵活、方便
- Lock实现提供比使用synchronized方法和语句可以获得更广泛的锁定操作
- Lock是接口不能直接实例化,这里采用,他的实现类ReentrantLock来构建Lock锁对象
方法名称 | 说明 |
public ReentrantLock() | 获得Lock锁的实现类对象 |
方法名称 | 说明 |
void lock() | 获得锁 |
void unlock() | 释放锁 |
线程通信
什么是线程通信?
- 线程通信是线程间相互发送数据,线程通信通常通过共享一个数据的方式实现
- 线程间会根据共享数据的情况来决定自己该做什么,以及通知其他线程该怎么做
线程通信常见模型
- 生产者与消费者模型:生产者线程负责圣生产数据,消费者线程负责消费数据
- 要求:生产者线程生产完数据后,唤醒消费者,然后等待自己;消费者消费完数据后,唤醒生产者,然后等待自己。
线程通信的前提:线程通信通常是在多个线程操作同一个共享资源的时候需要进行的通信,且要保证线程安全。
线程通信的三个常见方法
方法名称 | 说明 |
void wait() | 当前线程等待,直到另一个线程调用notify()或notifiAll()唤醒自己 |
void notify() | 唤醒正在等待对象监视器(锁监视对象)的单个线程 |
void notifyAll() | 唤醒正在等待对象检测器(锁对象)的所有进程 |
注意:上述方法应该使用当前同步锁(this)对象进行调用
线程池【重点】
什么是线程池?
- 线程池就是一个可以服用线程技术。
不使用线程池的问题
- 如果用户每发起一个请求,然后后台就创建一个新线程来处理,下次新任务来了又要创建新线程,而新线程的开销是很大的,这样会严重影响系统的性能。
谁代表线程池?
JDK5.0起提供了代表线程池的接口:Executor Service
如何得到线程池对象
- 方式一:使用ExecutorService的实现类ThreadPoolExecutor自创建一个线程池对象
- 方式二:使用Executors(线程池的工具类)调用方法返回不同特点的线程池对象
线程池常见面试题
临时线程什么时候创建?
- 新任务提交时发现核心线程都在忙,任务队列也满了,并且还可以创建临时线程,此时才会创建临时线程。
什么时候会开始拒绝任务?
- 核心线程和临时线程都在忙,任务队列也满了,新的任务过来才会开始任务拒绝。
谁代表线程池?
ExecutorService接口 :已知实现类:
AbstractExecutorService
, ForkJoinPool
ScheduledThreadPoolExecutor
, ThreadPoolExecutor(重点)
ThreadPoolExecutor创建线程池对象示例
//创建线程池对象
ExecutorService pool =new ThreadPoolExecutor(3(核心线程),5(最大线程数), 6(最大存活时间),TimeUnit.SECONDS(指定存活时间单位), new ArrayBlockingQueue<>(5)(指定任务队列),Executors.defaultThreadFactory()(指定线程工厂创建线程),new ThreadPoolExecutor.AbortPolicy()(新任务来了处理办法));
方法名称 | 说明 |
void execute(Runnable command) | 执行任务/命令,没有返回值,一般用来执行Runnable任务 |
Future<T> submit(Callable<T> task) | 执行任务,返回未来任务对象获取线程结果,一班拿来执行Callable任务 |
void shutdown() | 等任务执行完毕后关闭线程 |
List<Runnable> shutdownNow() | 立刻关闭,停止正在执行的任务,并返回队列中未执行的任务 |
策略 | 详解 |
ThreadPoolExecutor.AbortPolicy | 丢弃任务并抛出RejectedExecutionExeceotion异常。是默认策略 |
ThreadPoolExecutor.DiscardPolicy | 丢弃任务,但是不抛出异常,这是不推荐的做法 |
ThreadPoolExecutor.DiscardoldesPolicy | 抛出队列中等待最久的任务 然后把房钱队列加入队列中 |
ThreadPoolExecutor.CallerRunnablePolicy | 由主线程负责调用任务的run()方法从而绕过线程池直接执行 |
线程池如何处理Runnable任务
- 使用ExecutorService的方法
- void execute(Runnable target)
线程池处理Callable任务
方法名称 | 说明 |
void execute(Runnable command) | 执行任务/命令,没有返回值,一般执行Ruannable任务 |
Future<T> submit(Callable<T> task) | 执行Callsble任务,返回未来任务对象获得线程结果 |
void shutdown() | 等任务执行完毕后关闭线程池 |
List<Runnable> shutdownNow() | 立刻关闭,停止正在执行的任务,并返回队列中未执行的任务 |
线程池如何处理Callable任务,并得到任务执行完毕后返回的结果
- 使用ExecutorService的方法:
- Future<T> submit(Callable<t> command)
Executors工具类实现线程池
Executors工具类底层是基于什么方式实现的线程池对象?
- 线程池ExecutorService的实现类:ThreadPoolExecutor
Executor是否适合做大型互联网场景的线程池方案?
- 不合适
- 建议使用THreadPoolExecutor来指定线程池参数,这样可以明确线程池的运行规则,规避资源耗尽的风险
定时器
- 定时器是一种控制任务延时调用,或者周期调用的技术
- 作用:闹钟、定时邮件发送
定时器的实现方式
- 方式一:Timer
- 方式二:ScheduledExecutorService
构造器 | 说明 |
public Timer() | 创建Timer定时器对象 |
方法 | 说明 |
public void schedule(TimewTask, long delay ,long period) | 开启一个定时器,按照计划处理TimerTask任务 |
Timer定时器的特点和存在的问题
- Timer是单线程,处理多个任务按照顺序执行,存在延时与设置定时器的时间有出入
- 可能会因为其中其中某个任务的异常使Timer线程死掉,从而影响后续任务的执行。
ScheduledExecutorService定时器
ScheduledExecutorService是JDK1.5中引入了并发包,目的是为了弥补TImer的缺陷,ScheduledExecutorService内部为线程池。
Executors的方法 | 说明 |
public ScheduledExecutorService newScheduledThreadPool(int corePoolSize) | 得到线程池对象 |
ScheduledExecutorService的方法 | 说明 |
public ScheduledFuture<?> scheduleAtFixedRate(Runable command, long initaDelay, long period, TimeUi) | 周期调度方法 |
ScheduledExecutorService的优点
- 基于线程池,某个任务的执行情况不会影响其他定时任务的执行。
补充知识:并发、并行
并发与并行
- 正在执行的程序(软件)就是一个独立的进程,线程是属于进程的,多个线程其实就是并发与并行同时进行的。
并发的理解:
- CPU同时处理线程的数量有限。
- CPU会轮询为系统每个线程服务,由于CPU切换的速度很快,给我们的感觉是这些线程是同时执行的,这就是并发。
并行的理解:
- 在同一时刻上,同时有很多个线程在被CPU处理并执行。
并行与并发的含义:
- 并发:CPU分时轮询的执行线程
- 并行:同一时刻同时在执行
生命周期
线程的状态
- 线程的状态:就是线程从生到死的过程,记忆中间经历的各种非状态及状态转换。
- 理解线程的状态有利提升并发编程的理解能力。
Java线程的状态
- Java总共定义了6种状态
- 6种状态都定义在Thread的内部枚举类种。
线程的六种状态:
新建状态(NEW)-------------------> 创建线程对象
就绪状态(RUNNABLE)-------------------> start方法
阻塞状态(BLOCKED)-------------------> 无法获得锁对象
等待状态(WAITING)-------------------> wait方法
计时等待(TIME_WAITING)-------------------> sleep方法
结束状态(TERMINATED)-------------------> 全部代码运行完毕