JAVA并发实现三(线程的挂起和恢复)

时间:2021-11-09 23:52:47
package com.subject01;
/**
* 通过标识位,实现线程的挂起和回复
* com.subject01.AlternateSuspendResume.java
* @author 孙涛
* 2016年5月9日
*/
public class AlternateSuspendResume implements Runnable { private volatile int firstVal ;
private volatile int secondVal ;
// 线程挂起的标识
private volatile boolean suspendFlag ; @Override
public void run() {
// TODO Auto-generated method stub
try {
suspendFlag = false ;
firstVal = 0 ;
secondVal = 0 ;
workMethod();
} catch (Exception e) {
// TODO: handle exception
}
} private boolean areValueEqual(){
return firstVal == secondVal ;
} private void workMethod() throws InterruptedException{
int val = 1 ;
while(true){
// 仅当线程挂起的时候,才运行这段代码
waitWhileSuspended(); stepOne(val);
stepTwo(val);
val++ ; // 仅当线程挂起的时候才运行这段代码
waitWhileSuspended(); Thread.sleep(200);
}
} private void stepTwo(int val) {
secondVal = val ;
} private void stepOne(int val) throws InterruptedException {
firstVal = val ;
Thread.sleep(300);
} private void waitWhileSuspended() throws InterruptedException {
//这是一个“繁忙等待”技术的示例。
//它是非等待条件改变的最佳途径,因为它会不断请求处理器周期地执行检查,
while(suspendFlag){
Thread.sleep(200);
}
} private void supendRequest() {
this.suspendFlag = true ;
} private void resumeRequest() {
this.suspendFlag = false ;
} public static void main(String[] args) {
AlternateSuspendResume asr = new AlternateSuspendResume();
Thread t = new Thread(asr);
t.start();
try {
Thread.sleep(2000);
} catch (Exception e) {
} for (int i = 0; i < 10; i++) {
asr.supendRequest();
//让线程有机会注意到挂起请求
//注意:这里休眠时间一定要大于
//stepOne操作对firstVal赋值后的休眠时间,即300ms,
//目的是为了防止在执行asr.areValuesEqual()进行比较时,
//恰逢stepOne操作执行完,而stepTwo操作还没执行
try { Thread.sleep(350); }
catch ( InterruptedException x ) { } System.out.println("dsr.areValuesEqual()=" +
asr.areValueEqual()); asr.resumeRequest(); try {
//线程随机休眠0~2秒
Thread.sleep(
( long ) (Math.random() * 2000.0) );
} catch ( InterruptedException x ) {
//略
}
} System.exit(0); //退出应用程序
}
}

 |--通过标识位合理的控制线程挂起的位置; 

|--线程终止:线程在执行完run()方法之后,或者在run()中使用return,都可以将线程进行终止;同时也可以通过标识位灵活的控制线程终止的位置;

参考地址:http://blog.csdn.net/ns_code/article/details/17095733

JAVA并发实现三(线程的挂起和恢复)的更多相关文章

  1. Java并发编程:线程控制

    在上一篇文章中(Java并发编程:线程的基本状态)我们介绍了线程状态的 5 种基本状态以及线程的声明周期.这篇文章将深入讲解Java如何对线程进行状态控制,比如:如何将一个线程从一个状态转到另一个状态 ...

  2. Java 并发编程:线程间的协作&lpar;wait&sol;notify&sol;sleep&sol;yield&sol;join&rpar;

    Java并发编程系列: Java 并发编程:核心理论 Java并发编程:Synchronized及其实现原理 Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) Java 并发编程 ...

  3. Java并发编程:线程池的使用

    Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...

  4. Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition

    Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者 ...

  5. Java并发编程:线程池的使用(转)

    Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...

  6. Java并发编程:线程池的使用(转载)

    转载自:https://www.cnblogs.com/dolphin0520/p/3932921.html Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实 ...

  7. Java并发编程:线程池的使用&lpar;转载&rpar;

    文章出处:http://www.cnblogs.com/dolphin0520/p/3932921.html Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实 ...

  8. &lbrack;转&rsqb;Java并发编程:线程池的使用

    Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...

  9. 【转】Java并发编程:线程池的使用

    Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了, ...

  10. 19、Java并发编程:线程间协作的两种方式:wait、notify、notifyAll和Condition

    Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者 ...

随机推荐

  1. EC笔记:第三部分:17、使用独立的语句将newed对象放入智能指针

    一般的智能指针都是通过一个普通指针来初始化,所以很容易写出以下的代码: #include <iostream> using namespace std; int func1(){ //返回 ...

  2. opencv基于混合高斯模型的图像分割

    #include "stdafx.h" #include <opencv\cv.h> #include <opencv\highgui.h> #includ ...

  3. Java Web 开发利用Struts2&plus;Spring&plus;mybatis写一个用户登录界面以及简单的数据交互

    框架的东西太复杂也难以讲通,直接上代码: 一.首先得配置环境 和导入必要的jar包 有一些重要的如下: Filter文件夹下的SafetyFilter.java   model文件夹下的 Global ...

  4. python学习笔记 ——python写的猜数字游戏 002

    from sys import exit import random def Arrfor(str): #CONTST = CONTST + 1 artificial = input("请输 ...

  5. 新浪微博客户端&lpar;3&rpar;-封装UIBarButtonItem

    单独给NavigationBar上的两个NavigationItem设置图片显得比较麻烦,下面对创建单个UIBarButtonItem的过程进行封装. UIBarButtonItem+Extensio ...

  6. 7&period; 星际争霸之php设计模式--中介者模式

    题记==============================================================================本php设计模式专辑来源于博客(jymo ...

  7. SVN与TortoiseSVN实战:冲突详解(二)

    硬广:<SVN与TortoiseSVN实战>系列已经写了四篇,第二篇<SVN与TortoiseSVN实战:标签与分支>和第三篇<SVN与TortoiseSVN实战:Tor ...

  8. NumPy的array

    1.numpy包中的array数组,用于弥补列表可以存储任意的数据类型的不足,因为有时候我们需要存储某种类型的数据在数组中,这才是数组的本来内涵.我们通过向numpy.array()函数中传递pyth ...

  9. Android手机外置SD卡&lpar;TF卡&rpar;的获取方法

    Android手机上的外置SD卡,起初的时候,即在Android出世的前几年,那时手机的存储是十分有限的,不像现在到处可见16G.32G和64G的存储,因而那时候的手机有的厂商允许插入外置的SD卡,此 ...

  10. &period;Net cxy 提高效率

    Visual Studio Visual Studio Productivity Power tool: VS 专业版的效率工具. Web Essentials: 提高开发效率,能够有效的帮助开发人员 ...