Java原子更新类

Posted 2022-01-21 水田如雅

 @Test
    public void test6() throws Exception 
        AtomicInteger value = new AtomicInteger(0);
        CyclicBarrier cyclicBarrier = new CyclicBarrier(100);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 100; i++) 
            executorService.submit(new Runnable() 
                @SneakyThrows
                @Override
                public void run() 
                    System.out.println(value.getAndIncrement());
                    cyclicBarrier.await();
                
            );
        
        cyclicBarrier.await();
        System.out.println("value" + value);
    

    @Test
    public void test7() throws Exception 
        int[] arr = 0, 1, 2;
        AtomicIntegerArray valueArr = new AtomicIntegerArray(arr);
        CyclicBarrier barrier = new CyclicBarrier(100);
        for (int i = 0; i < 100; i++) 
            new Thread() 
                @SneakyThrows
                @Override
                public void run() 
                    valueArr.getAndAdd(0, 1);
                    barrier.await();
                
            .start();
        
        barrier.await();
        System.out.println(JSONObject.toJSONString(valueArr.get(0)));
    


    @Test
    public void test8() throws Exception 
        Person person = new Person("lhc", 0);
        AtomicReference<Person> personAtomicReference = new AtomicReference<>(person);
        CyclicBarrier barrier = new CyclicBarrier(100);
        for (int i = 0; i < 100; i++) 
            new Thread() 
                @SneakyThrows
                @Override
                public void run() 
                    System.out.println(personAtomicReference.compareAndSet(person, new Person("lhc", 11)));
                    barrier.await();
                
            .start();
        
        barrier.await();
        System.out.println(JSONObject.toJSONString(personAtomicReference.get().getAge()));
    

    @Test
    public void test9() throws Exception 
        Person person = new Person("lhc", 0);
        AtomicIntegerFieldUpdater<Person> updater = AtomicIntegerFieldUpdater.newUpdater(Person.class, "age");
        CyclicBarrier barrier = new CyclicBarrier(100);
        for (int i = 0; i < 100; i++) 
            new Thread() 
                @SneakyThrows
                @Override
                public void run() 
                    updater.addAndGet(person, 1);
                    barrier.await();
                
            .start();
        
        barrier.await();
        System.out.println(JSONObject.toJSONString(updater.get(person)));