整形的++是否是原子性的示例

た入场券 2022-05-19 13:35 141阅读 0赞

首先,整形的操作是非原子性的,需要使用同步手段来进行同步

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class AtomicityThread implements Runnable {
        private int threadnum;
        /**
         * 使用volatile和不使用volatile的区别在于JVM内存主存和线程工作内存的同步之上。
         * volatile保证变量在线程工作内存和主存之间一致。 
         * volatile的作用.可参考：http://rwl6813021.iteye.com/blog/349169
         * http://blog.sina.com.cn/s/blog_5a4267fa0100axw2.html
         */
        private int count = 0;//加上volatile也不行,因为volatile仅仅只是解决了存储的问题
    //  private AtomicInteger count = new AtomicInteger(0);//使用这种方式可以达到原子性的效果
        
        public AtomicityThread() {
             threadnum = 1000;
        }
        
        public AtomicityThread(int threadnum) {
            this.threadnum = threadnum;
        }
        
        public Lock lock = new ReentrantLock();
        @Override
        public void run() {
            for (int i = 0; i < threadnum; i++) {//这里的i++是原子性的,因为它在方法内,不涉及多线程的问题
            	lock.lock();//使用锁机制的话也可以达到原子性的效果
                    count++;
                    lock.unlock();
    //        	count.incrementAndGet();//这是使用AtomicInteger的操作代码
            }
        }
        
        public static void main(String[] args) {
            ExecutorService executorService = Executors.newCachedThreadPool();
            AtomicityThread multiThread =new AtomicityThread();
            for (int i = 0; i < 1000; i++) {
                executorService.execute(multiThread);
            }
            executorService.shutdown();
            try {
            	//这里需要停顿一些时间,以避免上述的整形操作未完成,就在下面打印结果
            	//如果循环的次数增加,可让休眠的时间增加,以得到正确的运行结果
    			Thread.sleep(2000);
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
            System.out.println("#"+multiThread.count);
        }
    }