转载请注明出处:http://blog.csdn.net/ns_code/article/details/17095733
挂起和恢复线程
Thread 的API中包含两个被淘汰的方法,它们用于临时挂起和重启某个线程,这些方法已经被淘汰,因为它们是不安全的,不稳定的。如果在不合适的时候挂起线程(比如,锁定共享资源时),此时便可能会发生死锁条件——其他线程在等待该线程释放锁,但该线程却被挂起了,便会发生死锁。另外,在长时间计算期间挂起线程也可能导致问题。
下面的代码演示了通过休眠来延缓运行,模拟长时间运行的情况,使线程更可能在不适当的时候被挂起:
- public class DeprecatedSuspendResume extends Object implements Runnable{
- //volatile关键字,表示该变量可能在被一个线程使用的同时,被另一个线程修改
- private volatile int firstVal;
- private volatile int secondVal;
- //判断二者是否相等
- public boolean areValuesEqual(){
- return ( firstVal == secondVal);
- }
- public void run() {
- try{
- firstVal = 0;
- secondVal = 0;
- workMethod();
- }catch(InterruptedException x){
- System.out.println("interrupted while in workMethod()");
- }
- }
- private void workMethod() throws InterruptedException {
- int val = 1;
- while (true){
- stepOne(val);
- stepTwo(val);
- val++;
- Thread.sleep(200); //再次循环钱休眠200毫秒
- }
- }
- //赋值后,休眠300毫秒,从而使线程有机会在stepOne操作和stepTwo操作之间被挂起
- private void stepOne(int newVal) throws InterruptedException{
- firstVal = newVal;
- Thread.sleep(300); //模拟长时间运行的情况
- }
- private void stepTwo(int newVal){
- secondVal = newVal;
- }
- public static void main(String[] args){
- DeprecatedSuspendResume dsr = new DeprecatedSuspendResume();
- Thread t = new Thread(dsr);
- t.start();
- //休眠1秒,让其他线程有机会获得执行
- try {
- Thread.sleep(1000);}
- catch(InterruptedException x){}
- for (int i = 0; i < 10; i++){
- //挂起线程
- t.suspend();
- System.out.println("dsr.areValuesEqual()=" + dsr.areValuesEqual());
- //恢复线程
- t.resume();
- try{
- //线程随机休眠0~2秒
- Thread.sleep((long)(Math.random()*2000.0));
- }catch(InterruptedException x){
- //略
- }
- }
- System.exit(0); //中断应用程序
- }
- }
某次运行结果如下:
从areValuesEqual()返回的值有时为true,有时为false。以上代码中,在设置firstVal之后,但在设置secondVal之前,挂起新线程会产生麻烦,此时输出的结果会为false(情况1),这段时间不适宜挂起线程,但因为线程不能控制何时调用它的suspend方法,所以这种情况是不可避免的。
当然,即使线程不被挂起(注释掉挂起和恢复线程的两行代码),如果在main线程中执行asr.areValuesEqual()进行比较时,恰逢stepOne操作执行完,而stepTwo操作还没执行,那么得到的结果同样可能是false(情况2)。
下面我们给出不用上述两个方法来实现线程挂起和恢复的策略——设置标志位。通过该方法实现线程的挂起和恢复有一个很好的地方,就是可以在线程的指定位置实现线程的挂起和恢复,而不用担心其不确定性。
对于上述代码的改进代码如下:
- public class AlternateSuspendResume extends Object implements Runnable {
- private volatile int firstVal;
- private volatile int secondVal;
- //增加标志位,用来实现线程的挂起和恢复
- private volatile boolean suspended;
- public boolean areValuesEqual() {
- return ( firstVal == secondVal );
- }
- public void run() {
- try {
- suspended = false;
- firstVal = 0;
- secondVal = 0;
- workMethod();
- } catch ( InterruptedException x ) {
- System.out.println("interrupted while in workMethod()");
- }
- }
- private void workMethod() throws InterruptedException {
- int val = 1;
- while ( true ) {
- //仅当贤臣挂起时,才运行这行代码
- waitWhileSuspended();
- stepOne(val);
- stepTwo(val);
- val++;
- //仅当线程挂起时,才运行这行代码
- waitWhileSuspended();
- Thread.sleep(200);
- }
- }
- private void stepOne(int newVal)
- throws InterruptedException {
- firstVal = newVal;
- Thread.sleep(300);
- }
- private void stepTwo(int newVal) {
- secondVal = newVal;
- }
- public void suspendRequest() {
- suspended = true;
- }
- public void resumeRequest() {
- suspended = false;
- }
- private void waitWhileSuspended()
- throws InterruptedException {
- //这是一个“繁忙等待”技术的示例。
- //它是非等待条件改变的最佳途径,因为它会不断请求处理器周期地执行检查,
- //更佳的技术是:使用Java的内置“通知-等待”机制
- while ( suspended ) {
- Thread.sleep(200);
- }
- }
- public static void main(String[] args) {
- AlternateSuspendResume asr =
- new AlternateSuspendResume();
- Thread t = new Thread(asr);
- t.start();
- //休眠1秒,让其他线程有机会获得执行
- try { Thread.sleep(1000); }
- catch ( InterruptedException x ) { }
- for ( int i = 0; i < 10; i++ ) {
- asr.suspendRequest();
- //让线程有机会注意到挂起请求
- //注意:这里休眠时间一定要大于
- //stepOne操作对firstVal赋值后的休眠时间,即300ms,
- //目的是为了防止在执行asr.areValuesEqual()进行比较时,
- //恰逢stepOne操作执行完,而stepTwo操作还没执行
- try { Thread.sleep(350); }
- catch ( InterruptedException x ) { }
- System.out.println("dsr.areValuesEqual()=" +
- asr.areValuesEqual());
- asr.resumeRequest();
- try {
- //线程随机休眠0~2秒
- Thread.sleep(
- ( long ) (Math.random() * 2000.0) );
- } catch ( InterruptedException x ) {
- //略
- }
- }
- System.exit(0); //退出应用程序
- }
- }
运行结果如下:
线程挂起的位置不确定main线程中执行asr.areValuesEqual()进行比较时,恰逢stepOne操作执行完,而stepTwo操作还没执行)asr.areValuesEqual()操作前,让main线程休眠450ms(>300ms),如果挂起请求发出时,新线程正执行到或即将执行到stepOne操作(如果在其前面的话,就会响应挂起请求,从而挂起线程),那么在stepTwo操作执行前,main线程的休眠还没结束,从而main线程休眠结束后执行asr.areValuesEqual()操作进行比较时,stepTwo操作已经执行完,因此也不会出现输出结果为false的情况。
可以将ars.suspendRequest()代码后的sleep代码去掉,或将休眠时间改为200(明显小于300即可)后,查看执行结果,会发现结果中依然会有出现false的情况。如下图所示:
总结:线程的挂起和恢复实现的正确方法是:通过设置标志位,让线程在安全的位置挂起
终止线程
当调用Thread的start()方法,执行完run()方法后,或在run()方法中return,线程便会自然消亡。另外Thread
API中包含了一个stop()方法,可以突然终止线程。但它在JDK1.2后便被淘汰了,因为它可能导致数据对象的崩溃。一个问题是,当线程终止时,很少有机会执行清理工作;另一个问题是,当在某个线程上调用stop()方法时,线程释放它当前持有的所有锁,持有这些锁必定有某种合适的理由——也许是阻止其他线程访问尚未处于一致性状态的数据,突然释放锁可能使某些对象中的数据处于不一致状态,而且不会出现数据可能崩溃的任何警告。
终止线程的替代方法:同样是使用标志位,通过控制标志位来终止线程。
转: 【Java并发编程】之三:线程挂起、恢复与终止的正确方法(含代码)的更多相关文章
-
Java并发编程:线程控制
在上一篇文章中(Java并发编程:线程的基本状态)我们介绍了线程状态的 5 种基本状态以及线程的声明周期.这篇文章将深入讲解Java如何对线程进行状态控制,比如:如何将一个线程从一个状态转到另一个状态 ...
-
Java 并发编程:线程间的协作(wait/notify/sleep/yield/join)
Java并发编程系列: Java 并发编程:核心理论 Java并发编程:Synchronized及其实现原理 Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) Java 并发编程 ...
-
Java并发编程之三:volatile关键字解析 转载
目录: <Java并发编程之三:volatile关键字解析 转载> <Synchronized之一:基本使用> volatile这个关键字可能很多朋友都听说过,或许也都用过 ...
-
Java并发编程:线程池的使用
Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...
-
Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition
Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者 ...
-
Java并发编程:线程池的使用(转)
Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...
-
(转)Java并发编程:线程池的使用
背景:线程池在面试时候经常遇到,反复出现的问题就是理解不深入,不能做到游刃有余.所以这篇博客是要深入总结线程池的使用. ThreadPoolExecutor的继承关系 线程池的原理 1.线程池状态(4 ...
-
Java并发编程:线程池的使用(转载)
转载自:https://www.cnblogs.com/dolphin0520/p/3932921.html Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实 ...
-
Java并发编程:线程池的使用(转载)
文章出处:http://www.cnblogs.com/dolphin0520/p/3932921.html Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实 ...
-
[转]Java并发编程:线程池的使用
Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...
随机推荐
-
用AE (Adobe After Effects) 处理视频
这话要从年会说起,我们组的年会节目需要一段场外亲友团的评价视频,于是我们就靠在公司门口的logo前拍了这么一段.但是呢,有很多的不理想: 画面抖动 杂音好烦(中午吃饭时拍的,还有好大的微波炉好了的声音 ...
-
poj1949Chores(建图或者dp)
/* 题意:n个任务,有某些任务要在一些任务之前完成才能开始做! 第k个任务的约束只能是1...k-1个任务!问最终需要最少的时间完成全部的 任务! 思路:第i个任务要在第j个任务之前做,就在i,j之 ...
-
Android开发-修改AVD路径
最近清理系统的时候发现C盘下有个.android文件夹占了大概10G的空间,这可怎么办,后来证实是AVD的缘故,只能修改AVD路径了. 以下是修改AVD路径的方法: 1.创建新的环境变量,ANDROI ...
-
WEB服务器、应用程序服务器、HTTP服务器区别(转)
WEB服务器.应用程序服务器.HTTP服务器有何区别?IIS.Apache.Tomcat.Weblogic.WebSphere都各属于哪种服务器,这些问题困惑了很久,今天终于梳理清楚了: Web服务器 ...
-
用Node.js写爬虫,撸羞羞的图片
说到爬虫,很多人都认为是很高大上的东西.哇塞,是不是可以爬妹纸图啊,是不是可以爬小片片啊.答案就是对的.爬虫可以完成这些东西的操作.但是,作为一个正直的程序员,我们要在法律允许范围内用爬虫来为我们服务 ...
-
C# 中String.Join()方法
今天在工作中看到了组里一个大佬写的代码,感触颇多,同样实现一个需求,我写循环费了老大劲,代码又臭又长,大佬的代码简洁明了,三行搞定...不得不说,今天赚大了 简单总结一下今天赚到的知识 string里 ...
-
Day2数据结构和算法
2019-02-28,10:23:52 算法效率的度量方法 事后统计方法:为每一个程序编制测试程序 ,比较时间.(很麻烦,没有普遍适用性) 事前分析估算方法:在计算机程序编写前,依据统计方法对算法进行 ...
-
Python全栈开发之路 【第六篇】:Python基础之常用模块
本节内容 模块分类: 好处: 标准库: help("modules") 查看所有python自带模块列表 第三方开源模块: 自定义模块: 模块调用: import module f ...
-
KDevelop使用经验
KDevelop中不显示行号: 1.上方菜单栏"编辑器"->查看->Show Line Numbers 2.设置->配置编辑器->Appearance-&g ...
-
slideout
这里在原有slideout.js增加了shade的遮罩功能 核心: 1,此插件的使用需要配合dom来用: <!-- 左边 --> <nav id="menu" c ...