网络网站建设推广,怎么推广我做的网站,wordpress前端库加速,深圳品牌营销推广Atomic系列类别
Atomic系列类封装了一系列的基础类型和对象操作#xff0c;其主要目的就是为了实现原子性#xff0c;主要核心类如下
AtomicIntegerAtomicLongAtomicBooleanAtomicIntegerArrayAtomicLongArrayAtomicReference 原子性的引用对象在对Atomic类操作的时候…Atomic系列类别
Atomic系列类封装了一系列的基础类型和对象操作其主要目的就是为了实现原子性主要核心类如下
AtomicIntegerAtomicLongAtomicBooleanAtomicIntegerArrayAtomicLongArrayAtomicReference 原子性的引用对象在对Atomic类操作的时候如果是有多个操作执行那么就是非原子性的需要加synchronized进行修饰保证Atomic类操作整体原子性
package com.example.core.cas;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;public class UseAtomic {private static /* int count 0*/AtomicInteger count new AtomicInteger(0);public synchronized int add(){//使用synchronized关键字使得多个操作合并在一起形成一个整体//return count.addAndGet(10);将1234代替10模拟多个操作count.addAndGet(1);count.addAndGet(2);count.addAndGet(3);count.addAndGet(4);return count.get();}public static void main(String[] args) {UseAtomic ua new UseAtomic();ListThread list new ArrayList();//如果使用atomicInteger最终结果一定是1000for (int i0;i100;i){list.add(new Thread(new Runnable() {Overridepublic void run() {System.out.println(累计结果ua.add());}}));}for(Thread t:list){t.start();}}
}
另一个例子
Person.class
package com.example.core.cas;public class Person {private String name;private int age;public Person(String name, int age) {super();this.name name;this.age age;}public String getName() {return name;}public void setName(String name) {this.name name;}public int getAge() {return age;}public void setAge(int age) {this.age age;}public String toString() {return [name: this.name , age: this.age ];}
}多个线程抢占同一份资源会造成问题
package com.example.core.cas;public class UseAtomicReference1 {private static Person person;public static void main(String[] args) throws InterruptedException {person new Person(Tom, 18);System.out.println(Person is person.toString());Thread t1 new Thread(new Task1());Thread t2 new Thread(new Task2());t1.start();t2.start();t1.join();t2.join();Thread.sleep(100);System.out.println(Now Person is person.toString());}static class Task1 implements Runnable {public void run() {person.setAge(19);person.setName(Tom1);System.out.println(Thread1 Values person.toString());}}static class Task2 implements Runnable {public void run() {person.setAge(20);person.setName(Tom2);System.out.println(Thread2 Values person.toString());}}}使用Atomic如果两个线程逐次访问并修改资源可以保证数据一致性如果同时访问其中一个就会返回false不修改数据避免产生并发行
package com.example.core.cas;import java.util.concurrent.atomic.AtomicReference;public class UseAtomicReference2 {// 普通引用private static Person person;// 原子性引用private static AtomicReferencePerson aRperson;public static void main(String[] args) throws InterruptedException {person new Person(Tom, 18);aRperson new AtomicReferencePerson(person);System.out.println(Atomic Person is aRperson.get().toString());Thread t1 new Thread(new Task1());Thread t2 new Thread(new Task2());t1.start();t2.start();t1.join();t2.join();Thread.sleep(500);System.out.println(Now Atomic Person is aRperson.get().toString());}static class Task1 implements Runnable { public void run() {System.err.println(ret // C A S 原子操作aRperson.compareAndSet( //10ms aRperson.get(), //如果满足我的预期就进行修改不满足就不修改new Person(Tom, aRperson.get().getAge() 1)));System.out.println(Thread1 Atomic References aRperson.get().toString());}}static class Task2 implements Runnable {public void run() {System.err.println(ret aRperson.compareAndSet( //8msaRperson.get(), //如果满足我的预期就进行修改不满足就不修改new Person(Tom, aRperson.get().getAge() 2)));System.out.println(Thread2 Atomic References aRperson.get().toString());}}
}
