java中Atomic类之AtomicBoolean
2016-05-26 18:17
555 查看
类
在java.util.concurrent.atomic包下,有AtomicBoolean , AtomicInteger, AtomicLong, AtomicReference等类,它们的基本特性就是在多线程环境下,执行这些类实例包含的方法时,具有排他性,即当某个线程进入方法,执行其中的指令时,不会被其他线程打断,而别的线程就像自旋锁一样,一直等到该方法执行完成,才由JVM从等待队列中选择一个另一个线程进入。举例说明
以AtomicBoolean为例,单线程执行普通的方法(如下),不会出现线程问题:package com.secbro.test.atomic; /** * @author zhuzhisheng * @Description * @date on 2016/5/26. */ public class NormalBoolean implements Runnable{ public static boolean exits = false; private String name; public NormalBoolean(String name){ this.name = name; } @Override public void run() { if(!exits){ exits = true; System.out.println(name + ",step 1"); System.out.println(name + ",step 2"); System.out.println(name + ",step 3"); exits = false; } else { System.out.println(name + ",step else"); } } public static void main(String[] args) { new NormalBoolean("张三").run(); } }
然而,当多线程执行时,就会出现在执行判断之后的命令时,会有其他线程插入,变更exits的值。如下段代码:
package com.secbro.test.atomic; /** * @author zhuzhisheng * @Description * @date on 2016/5/26. */ public class NormalBoolean2 implements Runnable{ public static boolean exits = false; private String name; public NormalBoolean2(String name) { this.name = name; } @Override public void run() { if(!exits){ try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } exits = true; System.out.println(name + ",step 1"); System.out.println(name + ",step 2"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(name + ",step 3"); exits = false; } else { System.out.println(name + ",step else"); } } }
同时执行两线程,打印结果为:
张三,step 1 李四,step 1 张三,step 2 李四,step 2 张三,step 3 李四,step 3
现在,使用AtomicBoolean就可以确保多线程的情况下安全的运行,只有一个线程进行业务处理。
package com.secbro.test.atomic; import java.util.concurrent.atomic.AtomicBoolean; /** * @author zhuzhisheng * @Description * @date on 2016/5/26. */ public class TestAtomicBoolean implements Runnable{ public static AtomicBoolean exits = new AtomicBoolean(false); private String name; public TestAtomicBoolean(String name) { this.name = name; } @Override public void run() { if(exits.compareAndSet(false,true)){ try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(name + ",step 1"); System.out.println(name + ",step 2"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(name + ",step 3"); exits.set(false); } else { System.out.println(name + ",step else"); } } }
当两个线程执行此类时,打印结果如下:
张三,step else 李四,step 1 李四,step 2 李四,step 3
测试类:
package com.secbro.test.atomic; /** * @author zhuzhisheng * @Description * @date on 2016/5/26. */ public class TestBoolean { public static void main(String[] args) { Thread thread1 = new Thread(new NormalBoolean2("李四")); Thread thread2 = new Thread(new NormalBoolean2("张三")); thread1.start(); thread2.start(); //------------------------------------------------------- Thread thread3 = new Thread(new TestAtomicBoolean("李四")); Thread thread4 = new Thread(new TestAtomicBoolean("张三")); thread3.start(); thread4.start(); } }
参考文章:http://thomaschen2011.iteye.com/blog/1468085
相关文章推荐
- java中Atomic类之AtomicBoolean
- 走过路过不要错过~教你用java抓取网页中你想要的东东~~
- iOS客户端、java服务器的通信用RSA加密
- java50中经典算法
- 如何使用JAVA语言抓取某个网页中的邮箱地址
- Java之父、子实例的内存控制
- java单例模式
- HDU2083JAVA
- spring mvc3 + fastjson
- Android——Android Sutido:[2]导入eclipse项目篇
- liunx 系统下面安装jdk
- 实现spring+mybatis+uncode dal,应用自动切换连接数据库
- [Java]Stack栈和Heap堆的区别(终结篇)
- getServletContext()空指针异常的原因 和 Servlet的init方法
- java实现二叉树的构建以及3种遍历方法(转)
- NetBeans 使用远程Git库
- java && & 区别
- eclipse 代码提示均无效的问题解决方案
- java中BitMap实现
- Java设计模式(四):原型模式深拷贝的两种实现方式,以及和new对象的性能测试对比