并发编程 — 并发数据类型

标签：

在并行环境中,同步(锁)操作是实现真正并行的最大敌人,而且大量的锁竞争严重消耗了系统资源,但在开发当中不能避免多条线程对共享变量的修改,JDK1.5后为我们提供了一组实现了无锁算法(CAS算法)的类,他们分别包装了Integer,Long,Boolean和Integer,Long对应的数组类型 


AtomicInteger(Long)核心方法: 

其他类或方法请参考JDK帮助文档 

      我们来看一下CAS算法在AtomicInteger中是如何体现出现到 

Java代码  

1. /** 
2.      * Atomically sets to the given value and returns the old value. 
3.      *  
4.      * @param newValue 
5.      *            the new value 
6.      * @return the previous value 
7.      */  
8.     public final int getAndSet(int newValue) {  
9.         for (;;) {                   // 死循环不停尝试,直到成功  
10.             int current = get();     // 获取当前值  
11.             // 若当前值未受其他线程影响,设置为新值,否则进入第二次循环  
12.             if (compareAndSet(current, newValue))  
13.                 return current;  
14.         }  
15.     }  

      在CAS算法当中,首先程序体处于一个无限循环当中,在获取当前值后,使用compareAndSet进行比较,若然其他线程对当值进行修改,compareAndSet將返回false从而进入第二次循环,直到成功.在硬件层面,绝大部分的现代处理器已经支持了原子化的CAS指令,在JDK5.0后JVM已可以使用这个指令来实现并发操作和并发数据结构 


      除了Integet和Long等自增类型的原子性操作类外,JDK还提供了更令人心动的类型AtomicReference<V>,他能引用所有的引用类型 

Java代码  

1. public class TestMain {  
2.     @Test  
3.     public void testAtomicReference() throws Exception {  
4.         /* 
5.          * 注意:  
6.          *      要使用AtomicReference引用的类最好重写equals方法 
7.          *      compareAndSet将会使用 == 来判断对象是否相等 
8.          */  
9.   
10.         RayTest test1 = new RayTest();  
11.         RayTest test2 = new RayTest();  
12.   
13.         // 初始化 AtomicReference,默认值为test1  
14.         AtomicReference<RayTest> reference = new AtomicReference<RayTest>(test1);  
15.   
16.         // 將test1替换为test2  
17.         reference.compareAndSet(test1, test2);  
18.   
19.         Assert.assertNotSame(test1, reference.get());  
20.         Assert.assertEquals(test2, reference.get());  
21.     }  
22. }  

在CAS算法当中,整个过程无需加锁,无需等待,无锁的操作实际上可以将多条线程的并发冲突处理由应用层面自行决定,从而提升系统的性能,但使用CAS算法的编码复杂度明显地增加,还好JDK已为我们提供了Atomic类让我们直接使用,推荐遇到类似需求直接使用已提供好的工具 

并发编程 — 并发数据类型

标签：

原文地址：http://www.cnblogs.com/zhenjava/p/4725983.html