廖雪峰Java11多线程编程-3高级concurrent包-5Atomic

Atomic

java.util.concurrent.atomic提供了一组原子类型操作:
如AtomicInteger提供了

  • int addAndGet(int delta)
  • int incrementAndGet()
  • int get()
  • int compareAndGet()
    Atomic类可以实现:
  • 无锁(lock-free)实现的线程安全(thread-safe)访问
    原理:CAS(Compare and Set)如果AtomicInteger实例的值是prev,就替换为next,返回true;否则,返回false
public int add1AndGet(AtomicInteger var){
    int prev, next;
    do{
            //prev设置为var的值
            prev = var.get();
            next = prev + 1;
    }while ( ! var.compareAndSet(prev, next)); //如果var的值是prev,就替换为next,返回true,终止循环;如果var的值不是prev,就什么也不做,返回false,继续循环
    //通过compareAndSet就保证了,在do while循环中,即使其他的线程在prev = var.get()后修改了var的值,最终结果也一定是正确的。
    return prev;
}

通常不需要直接使用do...while..来调用compileAndGet,而是用incrementAndGet()这种封装的方法

    AtomicLong var = new AtomicLong(0);
    public long getNextId(){ //多线程安全的id序列生成器
            return var.incrementAndGet();
    }
import java.util.concurrent.atomic.AtomicInteger;

class Counter{
    private AtomicInteger value = new AtomicInteger();
    public int add(int m){
        return this.value.addAndGet(m);
    }
    public int dec(int m){
        return this.value.addAndGet(-m);
    }
    public int get(){
        return this.value.get();
    }
}
public class Main{
    final static int LOOP = 100;
    public static  void main(String[] args) throws InterruptedException{
        Counter counter = new Counter();
        Thread t1 = new Thread(){
            public void run(){
                for(int i=0;i<LOOP;i++) {
                    counter.add(1);
                }
            }
        };
        Thread t2 = new Thread(){
            public void run(){
                for(int i=0;i<LOOP;i++){
                    counter.dec(1);
                }
            }
        };
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        System.out.println(counter.get());
        System.out.println("END");
    }
}

总结:

使用java.util.atomic提供的原子操作可以简化多线程编程

  • AtomicInteger/AtomicLong/AtomicArray
  • 原子操作实现了无锁的线程安全
  • 适用于计数器、累加器

原文地址:https://www.cnblogs.com/csj2018/p/11018766.html

时间: 2024-10-09 09:20:35

廖雪峰Java11多线程编程-3高级concurrent包-5Atomic的相关文章

廖雪峰Java11多线程编程-3高级concurrent包-1ReentrantLock

线程同步: 是因为多线程读写竞争资源需要同步 Java语言提供了synchronized/wait/notify 编写多线程同步很困难 所以Java提供了java.util.concurrent包: 更高级的同步功能 简化多线程程序的编写 JDK>= 1.5 java.util.locks.ReetrantLock用于替代synchronized加锁 ```#java synchronized(lockObj){ n = n + 1; } final Lock lock = new Reetra

廖雪峰Java11多线程编程-2线程同步-2synchronized方法

1.Java使用synchronized对一个方法进行加锁 class Counter{ int count = 0; public synchronized void add(int n){ count += n; } public synchronized void dec(int n){ count -= n; } public int get(){//读取一个int类型是原子操作,不需要同步 return count; } } class AddThread extends Thread

廖雪峰Java11多线程编程-4线程工具类-1ThreadLocal

class User{ String name; int level; public User(String name, int level){ this.name = name; this.level = level; } } class UserContext implements AutoCloseable{ static final ThreadLocal<User> context = new ThreadLocal<>(); public static User get

廖雪峰Java13网络编程-1Socket编程-3TCP多线程编程

TCP多线程编程 一个ServerSocket可以和多个客户端同时建立连接,所以一个Server可以同时与多个客户端建立好的Socket进行双向通信. 因此服务器端,当我们打开一个Socket以后,通常使用一个无限for循环,在这个for循环内部,每次调用accept方法,返回一个与远程客户新建的Socket连接,紧接着启动一个新的线程,来处理这个连接. ServerSocket ss = new ServerSocket(port); for( ; ; ){ Socket sock = ss.

廖雪峰Java6 IO编程-2input和output-4Filter模式

1.JDK提供的InputStream分为两类: 直接提供数据的InputStream * FileInputStream:从文件读取 * ServletInputStream:从HTTP请求读取数据 * Socket.getInputStream():从TCP连接读取数据 提供额外附加功能的FilterInputStream * 如果要给FileInputStream添加缓冲功能: BufferedFileInputStream extends FileInputStream * 如果要给Fi

廖雪峰Java2面向对象编程-3继承和多态-1继承

1.继承 继承是一种代码复用的方式. Student与Person有相同部分的代码. Student可以从Person继承,这样Student获得了Person的所有功能,只需要编写新增的功能即可.通过继承,可以实现代码的复用. 继承使用关键字extends,一个类只能有一个父类. 如果没有写明继承类,编译器会自动指定该类继承于基类Object. Person:超类super,父类,基类 Student:子类subclass,扩展类 Person.java //默认继承Object public

廖雪峰Java2面向对象编程-4抽象类和接口-1抽象类

每个子类都可以覆写父类的方法 如果父类的方法没有实际意义,能否去掉方法的执行语句?子类会报编译错误 如果去掉父类的方法,就失去了多态的特性 可以把父类的方法声明为抽象方法. 如果一个class定义了方法,但没有具体执行代码,这个方法就是抽象方法: 抽象方法用abstract修饰 抽象方法没有任何执行语句 因为无法执行抽象方法,因此这个类也必须声明为抽象类abstract class 无法实例化一个抽象类.如果子类不是抽象类,依旧可以被实例化. 抽象类作用: 抽象类用于被继承 抽象类可以强迫子类实

廖雪峰Java2面向对象编程-4抽象类和接口-2接口

抽象方法本质上是定义接口规范 public abstract class Person{ public abstract void run(); } public class Student extends Person{ @Override public void run(){} } public class Teacher extends Person{ @Override public void run(){} } 如果一个抽象类没有字段,所有方法全部是抽象方法,就可以把抽象类改写为接口i

廖雪峰Java13网络编程-1Socket编程-2TCP编程

在开发网络应用程序的时候,会遇到Socket这个概念. Socket是一个抽象概念,一个应用程序通过一个Socket来建立一个远程连接,而Socket内部通过TCP/IP协议把数据传输到网络. Socket/TCP/部分IP都是由操作系统提供的.不同的编程语言只是提供了对操作系统调用的加单的封装,例如Java提供的几个Socket相关的类就封装了操作系统提供的接口. 为什么需要Socket? 因为仅仅通过IP地址进行通信还不够,同一台计算机同一时间会运行多个网络程序.当计算机收到一个数据包的时候