广州市番禺区住房和建设局网站,平面设计师服务平台,如何做好产品网络推广,制作wordpress插件2019独角兽企业重金招聘Python工程师标准 使用AtomicInteger原子类进行 i 操作 可以有类似 synchronized 实现同步的效果。 原子操作是不能分割的整体#xff0c;没有其他线程能够中断或检查正在原子操作中的变量。一个原子类型就是一个原子操作可用的类型 使用AtomicInteger原子类进行 i 操作 可以有类似 synchronized 实现同步的效果。 原子操作是不能分割的整体没有其他线程能够中断或检查正在原子操作中的变量。一个原子类型就是一个原子操作可用的类型它可以在没有锁的情况下做到线程安全。 示例1 AddCountThread.java import java.util.concurrent.atomic.AtomicInteger;public class AddCountThread extends Thread {private AtomicInteger count new AtomicInteger(0);Overridepublic void run() {for(int i0;i10000;i){System.out.println(count.incrementAndGet());}}
} Run_Atomic.java public class Run_Atomic {public static void main(String[] args) {AddCountThread countService new AddCountThread();Thread t1 new Thread(countService);t1.start();Thread t2 new Thread(countService);t2.start();Thread t3 new Thread(countService);t3.start();Thread t4 new Thread(countService);t4.start();Thread t5 new Thread(countService);t5.start();}
} 输出结果成功地累加到 50000 但是原子类也并不是完全安全的比如以下例子 示例2 MyService.java import java.util.concurrent.atomic.AtomicLong;public class MyService {public static AtomicLong aiRef new AtomicLong();public void addNum() {System.out.println(Thread.currentThread().getName() 加了100之后的结果是 aiRef.addAndGet(100));aiRef.addAndGet(1);}
} MyThread.java public class MyThread extends Thread {private MyService myService;public MyThread (MyService myService) {super();this.myService myService;}Overridepublic void run() {myService.addNum();}
} Run3_1.java public class Run3_1 {public static void main(String[] args) {try {MyService myService new MyService();MyThread[] array new MyThread[8];for(int i0;iarray.length;i) {array[i] new MyThread(myService);}for (int i 0;iarray.length;i ){array[i].start();}Thread.sleep(1000);System.out.println(myService.aiRef.get());}catch (InterruptedException e) {e.printStackTrace();}}
} 输出结果 出现这种情况是因为addAndGet()方法是原子性的但方法和方法之间的调用却不是原子的。解决这样的问题必须用到同步。 给addNum() 方法加上 同步锁既解决以上问题。 转载于:https://my.oschina.net/xiaozhiwen/blog/1608118
