1. 线程和进程的区别?
程序由指令和数据组成,但这些指令要运行,数据要读写,就必须将指令加载至 CPU,数据加载至内存。在指令运行过程中还需要用到磁盘、网络等设备。进程就是用来加载指令、管理内存、管理 IO 的。
当一个程序被运行,从磁盘加载这个程序的代码至内存,这时就开启了一个进程。
一个线程就是一个指令流,将指令流中的一条条指令以一定的顺序交给 CPU 执行
一个进程之内可以分为一到多个线程。
二者对比
- 进程是正在运行程序的实例,进程中包含了线程,每个线程执行不同的任务
- 不同的进程使用不同的内存空间,在当前进程下的所有线程可以共享内存空间。
- 线程更轻量,线程的上下文切换成本一般上要比进程上下文切换低(上下文切换指的是从一个线程切换到另一个线程)
2. 并行与并发的区别?
单核 CPU
- 单核 CPU 下线程实际还是串行执行的
CPU | 时间片 1 | 时间片 2 | 时间片 3 |
---|---|---|---|
core | 线程 1 | 线程 2 | 线程 3 |
每个时间片只能由 1 个线程执行。
- 操作系统中有一个组件叫做任务调度器,将 cpu 的时间片(windows 下时间片最小约为 15 毫秒)分给不同的程序使用,只是由于 cpu 在线程间(时间片很短)的切换非常快,人类感觉是同时运行的。
- 总结为一句话就是:微观串行,宏观并行。(感觉是并行,实际是串行)
- 一般会将这种线程轮流使用 CPU 的做法称为并发(concurrent)
多核 CPU
每个核(core)都可以调度运行线程,这时候线程可以是并行的。
区别
并发(concurrent)是同一时间应对(dealing with)多件事情的能力
并行(parallel)是同一时间动手做(doing)多件事情的能力
3. 线程创建的方式有哪些?
共有 4 种方式可以创建线程,分别是:
- 继承 Thread 类
- 实现 runnable 接口
- 实现 Callable 接口
- 线程池创建线程
继承 Thread 类
public class MyThread extends Thread{@Overridepublic void run(){System.out.println("run");}public static void main(String[] args){// 创建MyThread对象MyThread t = new MyThread();// 调用start方法启动线程t.start();}
}
实现 Runnable 接口
public class MyRunnable implements Runnable{@Overridepublic void run(){System.out.println("run");}public static void main(String[] args){// 创建MyRunnable对象MyRunnable mr = new MyRunnable();// 创建Thread对象MyThread t = new MyThread(mr);// 调用start方法启动线程t.start();}
}
实现 Callable 接口
public class MyCallable implements Callable<String>{@Overridepublic String call()throws Exception{System.out.println("run");return "ok";}public static void main(String[] args) throws ExecutionException,InterruptedException{// 创建MyRunnable对象MyCallable mr = new MyCallable();// 创建Future TaskFutureTask<String> ft = new FutureTask<String>(mr);// 创建Thread对象MyThread t = new MyThread(mr);// 调用start方法启动线程t.start();// 调用ft的get方法获取线程执行结果;String result = ft.get();}
}
注意:
- 接口后面的泛型和 call 方法的返回值一样。
- call 方法内就是线程要执行的内容。
- 这种方式对于需要线程返回结果的很合适。
线程池创建线程
public class MyExecutors implements Runnable{@Overridepublic void run(){System.out.println("run");}public static void main(String[] args){// 创建线程池对象ExecutorService threadPool = Executors.newFixedPool(3);threadPool.submit(new MyExecutors());// 关闭线程池threadPool.shutdown();}
}
追问:Runnable 和 Callable 的区别
- Runnable 接口 run 方法没有返回值。
- Callable 接口 call 方法有返回值,是个泛型,和 Future、FutureTask 配合可以用来获取异步执行的结果。
- Callable 接口的 call 方法允许抛出异常;而 Runnable 接口的 run 方法的异常只能在内部消化,不能继续上抛。
追问:在启动线程的时候,可以使用 run 方法吗?run() 和 start()有什么区别?
启动的线程的时候不可以使用 run 方法。
- start(): 用来启动线程,通过该线程调用 run 方法执行 run 方法中所定义的逻辑代码。start 方法只能被调用一次。
- run():封装了要被线程执行的代码,就是一个普通的方法,可以被调用多次。
4. 线程包括哪些状态,状态之间是如何变化的?
线程的状态可以参考 JDK 中的 Thread 类中的枚举 State
public enum State {/*** Thread state for a thread which has not yet started.*/// 尚未启动的线程的线程状态NEW,/*** Thread state for a runnable thread. A thread in the runnable* state is executing in the Java virtual machine but it may* be waiting for other resources from the operating system* such as processor.*/// 可运行线程的线程状态RUNNABLE,/*** Thread state for a thread blocked waiting for a monitor lock.* A thread in the blocked state is waiting for a monitor lock* to enter a synchronized block/method or* reenter a synchronized block/method after calling* {@link Object#wait() Object.wait}.*/// 线程阻塞等待监视器锁的线程状态BLOCKED,/*** Thread state for a waiting thread.* A thread is in the waiting state due to calling one of the* following methods:* <ul>* <li>{@link Object#wait() Object.wait} with no timeout</li>* <li>{@link #join() Thread.join} with no timeout</li>* <li>{@link LockSupport#park() LockSupport.park}</li>* </ul>** <p>A thread in the waiting state is waiting for another thread to* perform a particular action.** For example, a thread that has called <tt>Object.wait()</tt>* on an object is waiting for another thread to call* <tt>Object.notify()</tt> or <tt>Object.notifyAll()</tt> on* that object. A thread that has called <tt>Thread.join()</tt>* is waiting for a specified thread to terminate.*/// 等待线程的线程状态WAITING,/*** Thread state for a waiting thread with a specified waiting time.* A thread is in the timed waiting state due to calling one of* the following methods with a specified positive waiting time:* <ul>* <li>{@link #sleep Thread.sleep}</li>* <li>{@link Object#wait(long) Object.wait} with timeout</li>* <li>{@link #join(long) Thread.join} with timeout</li>* <li>{@link LockSupport#parkNanos LockSupport.parkNanos}</li>* <li>{@link LockSupport#parkUntil LockSupport.parkUntil}</li>* </ul>*/// 具有指定等待时间的等待线程的线程状态TIMED_WAITING,/*** Thread state for a terminated thread.* The thread has completed execution.*/// 已终止线程的线程状态,线程已完成执行TERMINATED;}
面试回答参考
- 线程包括哪些状态?
新建(NEW)、可执行(RUNNABLE)、阻塞(BLOCKED)、等待(WAITING)、时间等待(TIMED_WAITING)、终止(TERMINATED)
- 线程状态之间是如何变化的
- 创建线程对象是新建状态
- 调用了 start() 方法转变为可执行状态
- 线程获取到了 CPU 的执行权,执行结束是终止状态
- 在可执行状态的过程中,如果没有获取 CPU 的执行权,可能会切换其他状态
- 如果没有获取锁(synchronized 或 lock)进入**阻塞状态,**获得锁再切换为可执行状态
- 如果线程调用了 wait() 方法进入等待状态,其他线程调用 notify() 唤醒后可切换为可执行状态
- 如果线程调用了 sleep(50)方法,进入计时等待状态,到时间后可切换为可执行状态
5. 线程按顺序执行 join、notify 和 notifyall 的区别?
新建 T1、T2、T3 三个线程,如何保证它们按照顺序执行?
可以使用线程中的 join 方法解决。
join() 等待线程运行结束。例如,调用 t.join(),阻塞调用此方法的线程,使其进入 timed_waiting 状态,直到线程 t 执行完成后,此线程再继续执行。
public class JoinTest {public static void main(String[] args) {// 创建线程对象Thread t1 = new Thread(()->{System.out.println("t1");});Thread t2 = new Thread(()->{try {t1.join(); // 加入线程t1,只有t1线程执行完毕后,再次执行该线程} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("t2");});Thread t3 = new Thread(()->{try {t2.join(); // 加入线程t2,只有t2线程执行完毕后,再次执行该线程} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("t3");});// 启动线程t3.start();t2.start();t1.start();}
}
// 执行结果
t1
t2
t3
notify 和 notifyAll 有什么区别?
- notifyAll:唤醒所有 wait 的线程
- notify:只随机唤醒一个 wait 线程
6. Java 中 wait 和 sleep 方法的不同?
共同点
wait(),wait(long) 和 sleep(long) 的效果都是让当前线程暂时放弃 CPU 的使用权,进入阻塞状态。
不同点
- 方法归属不同
- sleep(long) 是 Thread 的静态方法
- 而 wait(),wait(long)都是 Object 的成员方法,每个对象都有
- 醒来时机不同
- 执行 sleep(long) 和 wait(long) 的线程都会在等待相应的毫秒后醒来
- wait(long) 和 wait() 还可以被 notify 唤醒,wait() 如果不唤醒就一直等下去
- 它们都可以被打断唤醒
- 锁特性不同(重点)
- wait 方法的调用必须先获取 wait 对象的锁(比如配合 synchronized 锁使用),而 sleep 则无此限制
- wait 方法执行后会释放对象锁,允许其它线程获得该对象锁
- sleep 方法如果在 synchronized 代码块中执行,并不会释放对象锁
7. 如何停止一个正在运行的线程?
有三种方式可以停止线程
- 使用退出标志,使线程正常退出,也就是当 run 方法完成后线程终止
public class MyInterrupt1 extends Thread{volatile boolean flag = false; // 线程执行的退出标记@Overridepublic void run(){while(!flag){System.out.println("MyThread...run...");try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}public static void main(String[] args) throws InterruptedException {// 创建MyThread对象MyInterrupt1 t1 = new MyInterrupt1();t1.start();// 主线程休眠6秒Thread.sleep(6000);// 更改标记为truet1.flag = true;}
}
// 执行结果
MyThread...run...
MyThread...run...
- 使用 stop 方法强行终止(不推荐,已作废)
- 使用 interrupt 方法中断线程
- 打断阻塞的线程(sleep、wait、join)的线程,线程会抛出 InterruptedException 异常
- 打断正常的线程,可以根据打断状态来标记是否退出线程
public class MyInterrupt3 {public static void main(String[] args) throws InterruptedException {// 1. 打断阻塞的线程Thread t1 = new Thread(()->{System.out.println("t1 正在运行。。。");try {Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}}, "t1");t1.start();Thread.sleep(500);t1.interrupt();System.out.println(t1.isInterrupted());// 2. 打断正常的线程
// Thread t2 = new Thread(()->{
// while(true){
// Thread current = Thread.currentThread();
// boolean interrupted = current.isInterrupted();
// if(interrupted){
// System.out.println("打断状态:"+ interrupted);
// break;
// }
// }
// },"t2");
// t2.start();
// Thread.sleep(500);
// t2.interrupt();}
}
//1执行结果
t1 正在运行。。。
false
Exception in thread "t1" java.lang.RuntimeException: java.lang.InterruptedException: sleep interruptedat MyInterrupt3.lambda$main$0(MyInterrupt3.java:9)at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.InterruptedException: sleep interruptedat java.lang.Thread.sleep(Native Method)at MyInterrupt3.lambda$main$0(MyInterrupt3.java:7)... 1 more
//2执行结果
打断状态:true