2.3.3解决异步死循环

测试

package com.cky.test;

public class RunThread extends Thread{
  private boolean isRunning = true;
  public boolean isRunning() {
      return isRunning;
  }

  public void setRunning(boolean isRunning) {
      this.isRunning = isRunning;

  }
  @Override
  public void run() {
     System.out.println("进入run方法");
     while(isRunning == true) {

     }
     System.out.println("线程被停止了");

  }

}
package com.cky.test;

public class Run {

    public static void main(String[] args) {
        try {
            RunThread runThread = new RunThread();
            runThread.start();
            Thread.sleep(1000);
            runThread.setRunning(false);
            System.out.println("已经赋值false");
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

程序处于死循环,为何呢?
代码线程被停止了从未被执行。

原因:

在启动RunThread.java线程时,变量private boolean isRunning=true;存在于公共堆栈及线程的私有堆栈中,在JVM被设置为-server模式时为了线程

运行的效率,线程一直在私有堆栈中取得isRunning的值是true.而代码thread.setrunning(false)虽然被执行,更新的却是公共堆栈中isRunning变量值false

所以一直就处于死循环状态。

这个问题就是私有堆栈中的值和公共堆栈中的值不同步造成的,解决这样的问题就是要使用volatile关键字,他的主要作用就是当线程访问isRunnging这个变量

时,强制性从公共堆栈中进行取值。

package com.cky.test;

public class RunThread extends Thread{
  volatile private boolean isRunning = true;
  public boolean isRunning() {
      return isRunning;
  }

  public void setRunning(boolean isRunning) {
      this.isRunning = isRunning;

  }
  @Override
  public void run() {
     System.out.println("进入run方法");
     while(isRunning == true) {

     }
     System.out.println("线程被停止了");

  }

}
进入run方法
已经赋值false
线程被停止了

通过使用volatile关键字,强制的从公共内存中读取变量,内存的结构如图。

使用volcatile关键字增加了实例变量在多个线程之间的可见性,但volatile关键字最致命的缺点是不支持原子性。

下面是和synchronized关键字的比较

1)关键字volatile是线程同步的轻量级实现,所以volatile性能比synchronized要好,并且volatile只能修饰变量,而synchronized可以修饰方法和代码块,随着

JDK新版本的发布,synchronized关键字在执行效率上得到很大的提高,在开发中使用synchronized还是很常见的,

2)多线程访问volatile不会发生堵塞,而synchronized会阻塞,

3)volatile能保证数据的可见性,不能保证原子性,而synchronized可以保证可见性和原子性,因为他会将私有内存和公共内存中的数据做同步,

4)volatile解决的是变量在多个线程之间的可见性,而synchronized关键字解决的是多个线程之间访问资源的同步性

线程安全包含原子性和可见性,java同步机制就是围绕这个两个方面来实现的,

时间: 2024-08-01 12:07:40

2.3.3解决异步死循环的相关文章

从头认识多线程-3.1 使用volatile解决异步死循环

这一章节我们来讨论一下使用volatile解决异步死循环. 1.在讨论上面的问题前,我们引入另一个例子:同步死循环 代码清单: package com.ray.deepintothread.ch03.topic_1; public class DeadFor { private boolean isStop = false; public boolean isStop() { return isStop; } public void setStop(boolean isStop) { this.

jquery.Deferred promise解决异步回调

我们先来看一下编写AJAX编码经常遇到的几个问题: 1.由于AJAX是异步的,所有依赖AJAX返回结果的代码必需写在AJAX回调函数中.这就不可避免地形成了嵌套,ajax等异步操作越多,嵌套层次就会越深,代码可读性就会越差. $.ajax({ url: url, data: dataObject, success: function(){ console.log("I depend on ajax result."); }, error: function(){} }); consol

JavaScript 解决异步顺序执行问题

开始用 for 循环异步调用数据的时候,发现异步的执行时在 for 循环后面执行.当然获取的结果也不是我想要的. 一般这种情况:我们可以通过下面方法解决 1.JQuery $ajax 设置ajax参数async为false,即与js同步,默认是true(异步). for(int i = 0 ; i < 5 ; i++){ var html= $.ajax({url: url,async: false}).responseText; } 2.可以利用递归的方法实现,当异步执行完成后在调用自身的函数

用订阅/发布者模式解决异步函数结果依赖的问题

我们都知道node是基于事件无阻塞i/o模型的,所以说大部分函数都是以异步实现的,请看下面代码: db.query(sql1, function (err, data) { //code }) db.query(sql2, function (err, data) { //code }) 如果我们上述两个操作,结果之间没有什么联系,那很好,基于node的I/O无阻塞模型,每个操作都做着自己的事情,美滋滋~ 但是在一些情况下这两个操作的结果有联系的,比如说第一个操作从数据库中取出一个人的姓,第二个

setInterval()解决异步加载,参数传递问题

如题,在异步加载获取页面数据时,有时会调用其他组件,当在传参时有时并不是所有参数都已加载. 异步加载数据获取异常的解决方法:setInterval() setInterval()这个方法可按照指定的周期(以毫秒计)来调用函数或计算表达式. setInterval(x(),y): x()代表你调用的方法, y是每隔多长时间调用一次x()方法 例如: setInterval(x(),1000):  每隔1秒调用一次x()方法 setInterval() 方法会不停地调用函数,直到clearInter

使用Primose方式解决异步编程回调的一些问题--animate动画的例子

function animate(dis, time) { var def = $.Deferred(); $('.boll') .animate({ left: dis + 'px' }, time, function() { def.resolve(time); }); return def; } $('.boll').on('click', function() { $.when( animate(50, 1000), animate(120, 100), animate(200, 500

解决异步回调方法中,初始化Cef时WPF界面卡死的问题

Application.Current.Dispatcher.BeginInvoke(new Action(() =>                            { })); 注意用Invoke同样会卡死,只能用BeginInvoke

requirejs解决异步模块加载方案

他首先会遍历enableRegistry取出其中定义的模块,并且将没有加载成功的模块标识注入noLoads数组,如果过期了这里就会报错 如果上述没问题还会做循环依赖的判断,主要逻辑在breakCycle中,因为我们这里不存在循环依赖便跳出了,但还未结束 我们这里开始了递归检测依赖是否载入 if ((!expired || usingPathFallback) && stillLoading) { //Something is still waiting to load. Wait for

promise解决异步嵌套问题

function a(){ return new Promise(function(res,rej){ $.ajax({ url:"a", type: "GET", async:true, dataType:"json", success:function(data){ console.log(data,"a"); res(data); } }) }); } function b(data){ console.log(data