Java多线程开发--多线程深入话题
内容学习于:edu.aliyun.com
1. 优雅的停止线程
在多线程操作之中如果要启动多线程肯定使用的是Thread类中的start()方法,而如果对于多线程需要进行停止处理,Thread类原本提供有stop()方法,但是对于这些方法从JDK 1.2版本开始就已经将其废除了,而且一直到现在也不再建议出现在你的代码之中,而除了stop()之外还有几个方法也被禁用了:
已经过期的方法:
- 停止多线程:public final void stop()
- 销毁多线程:public void destroy()
- 挂起线程:public final void suspend()、暂停执行
- 恢复挂起的线程:public final void resume()
之所以废除掉这些方法,主要的原因是因为这些方法有可能导致线程的死锁,所以从JDK 1.2 开始就都不建议使用了。如果这个时候要想实现线程的停止需要通过一种柔和的方式来进行。
实现线程柔和的停止代码:
public class ThreadDemo {
public static boolean flag = true;
public static void main(String[] args) {
new Thread(() -> {
long num = 0;
while (flag) {
try {
Thread.sleep(50);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在运行、num=" + num++);
}
}, "执行线程").start();
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
flag = false;
}
}
结果:
执行线程正在运行、num=0
执行线程正在运行、num=1
执行线程正在运行、num=2
执行线程正在运行、num=3
<mark>万一现在有其它的线程去控制这个flag的内容,那么这个时候对于线程的停止也不是说停就立刻停止的,而是会在执行中判断flag的内容来完成。</mark>
2. 后台守护线程
现在假设有一个人并且这个人有一个保镖,那么这个保镖一定是在这个人活着的时候进行守护,如果这不人已经死了,保镖没用了。所以在多线程里面可以进行守护线程的定义,也就是说如果现在主线程的程序或者其它的线程还在执行的时候,那么守护线程将一直存在,并且运行在后台状态。
在Thread类里面提供有如下的守护线程的操作方法:
- 设置为守护线程:public final void setDaemon(boolean on)
- 判断是否为守护线程:public final boolean isDaemon()
使用守护线程代码:
public class ThreadDemo {
public static void main(String[] args) {
Thread userThread = new Thread(() -> {
for (int x = 0; x < 10; x++) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在运行、x=" + x);
}
}, "用户线程");//完成核心业务
Thread daemonThread = new Thread(() -> {
for (int x = 0; x < Integer.MAX_VALUE; x++) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "正在运行、x=" + x);
}
}, "守护线程");//完成核心业务
daemonThread.setDaemon(true);//设置为守护线程
userThread.start();
daemonThread.start();
}
}
结果:
用户线程正在运行、x=0
守护线程正在运行、x=0
用户线程正在运行、x=1
守护线程正在运行、x=1
守护线程正在运行、x=2
用户线程正在运行、x=2
用户线程正在运行、x=3
守护线程正在运行、x=3
守护线程正在运行、x=4
用户线程正在运行、x=4
守护线程正在运行、x=5
用户线程正在运行、x=5
守护线程正在运行、x=6
用户线程正在运行、x=6
守护线程正在运行、x=7
用户线程正在运行、x=7
用户线程正在运行、x=8
守护线程正在运行、x=8
用户线程正在运行、x=9
守护线程正在运行、x=9
可以发现所有的守护线程都是围绕在用户线程的周围,如果程序执行完毕了,守护线程也就消失了,<mark>在整个的JVM里面最大的守护线程就是GC(垃圾回收)线程。程序执行中GC线程会一直存在,如果程序执行完毕,GC线程也将消失。</mark>
3. Volatile关键字
<mark>注:这个不是同步属性,表示直接内存操作该属性</mark>
在多线程的定义之中,volatile关键字主要是在属性定义上使用的,表示此属性为直接数据操作,而不进行副本的拷贝处理,这样的话在一些书上就将其错误的理解为同步属性了。
在正常进行变量处理的时候往往会经历如下的几个步骤:
- 获取变量原有的数据内容副本;
- 利用副本为变量进行数学计算;
- 将计算后的变量,保存到原始空间之中;
<mark>而如果一个属性上追加了volatile 关键字,表示的就是不使用副本,而是直接操作原始变量,相当于节约了: 拷贝副本、重新保存的步骤。</mark>
代码:
class TicketThread implements Runnable {
private volatile int ticket = 5;
private void sale() {
System.out.println(Thread.currentThread().getName() + "卖票、此时票数为" + this.ticket--);
}
@Override
public void run() {
while (true) {
if (ticket > 0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
this.sale();
}
}
}
}
public class ThreadDemo {
public static void main(String[] args) {
TicketThread mt = new TicketThread();
new Thread(mt, "票贩子A").start();
new Thread(mt, "票贩子B").start();
new Thread(mt, "票贩子C").start();
}
}
结果:
票贩子A卖票、此时票数为5
票贩子C卖票、此时票数为5
票贩子B卖票、此时票数为5
票贩子B卖票、此时票数为3
票贩子A卖票、此时票数为4
票贩子C卖票、此时票数为4
票贩子A卖票、此时票数为2
票贩子C卖票、此时票数为2
票贩子B卖票、此时票数为2
票贩子C卖票、此时票数为1
票贩子A卖票、此时票数为1
票贩子B卖票、此时票数为0
<mark>面试题:请解释volatile与synchronized的区别?</mark>
volatile 主要在属性上使用,而synchronized是在代码块与方法上使用的;
volatile 无法描述同步的处理,它只是一种直接内存的处理, 避免了副本的操作,而synchronized是实现同步的;