volatile关键字 Atomic类的使用示例

  1. volatile在只有一个线程写,但是存在多个线程读的时候使用,从而避免了使用synchronized,提高读写性能。
/**
 * valitile关键字
 *
 * @author xingguishuai
 * @create 2017-03-13-16:01
 **/
public class VolatileVariable extends Thread{

    private volatile Integer count = 0;
    public  void addCount(){
        System.out.println(Thread.currentThread().getName()+":count自增"+count++);
    }
    public  void run(){
        while (count < 3){
            //do nothing
        }
        //跳出循环结束,子线程结束
        System.out.println("count为"+count);
    }
    public static void main(String[] args) throws InterruptedException {
        //例1
        VolatileVariable volatileVariable = new VolatileVariable();
        //启动子线程,执行run方法
        volatileVariable.start();
        Thread.sleep(1000);
        volatileVariable.addCount();
        Thread.sleep(1000);
        volatileVariable.addCount();
        Thread.sleep(1000);
        volatileVariable.addCount();
}
  1. 当多个线程同时进行写操作时,不保证原子性,可以用atomic类来代替

例:

package com.fullstacker.study.course.concurrent;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * Atomic类示例,多线程间保持原子性
 *
 *
 * @author xingguishuai
 * @create 2017-03-14-10:33
 **/
public class AtomicCount {
    private static AtomicInteger atomicInteger = new AtomicInteger(0);
    /**
    * <p>功能描述:</p>
     * t1,t2,t3三个线程修改atomicInteger,
     * 由于AtomicInteger在进行修改操作时会对值“加锁”,所以AtomicInteger可以保持原子性,
     * 所以在三条线程都进行完修改后,最后的结果为3000,但在三条线程未完全结束时,输出的数字
     * 不一定。
    * @return
    * @param
    * @author xingguishuai
    * @Date 2017-03-16 15:43
    * @since 1.0
    */
    public static void main(String[] args){

        Thread t1 = new Thread(new Runnable() {
            @Override
            public void run() {
                int count =0;
                while(count<1000){
                    atomicInteger.incrementAndGet();
                    count++;
                }
                System.out.println(Thread.currentThread().getName()+":"+atomicInteger.get());
            }
        },"t1");
        Thread t2 = new Thread(new Runnable() {
            @Override
            public void run() {
                int count =0;
                while(count<1000){
                    atomicInteger.incrementAndGet();
                    count++;
                }
                System.out.println(Thread.currentThread().getName()+":"+atomicInteger.get());
            }
        },"t2");
        Thread t3 = new Thread(new Runnable() {
            @Override
            public void run() {
                for(int count=0;count<1000;count++){
                    atomicInteger.incrementAndGet();
                }
                System.out.println(Thread.currentThread().getName()+":"+atomicInteger.get());
            }
        },"t3");
        t1.start();
        t2.start();
        t3.start();
    }
}

源码可参考我的GitHub项目:https://github.com/iqijun/javastudy/blob/ed901c2187e535b5d00e0f113baca2ef10099ef3/src/main/java/com/fullstacker/study/course/concurrent

创作不易,转载请注明文章来源为www.full-satcker.com:邢桂帅 » volatile关键字 Atomic类的使用示例

赞 (1)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址