자바 동시성-AtomicInteger 클래스

java.util.concurrent.atomic.AtomicInteger 클래스는 원자 적으로 읽고 쓸 수있는 기본 int 값에 대한 연산을 제공하며 고급 원자 연산도 포함합니다. AtomicInteger는 기본 int 변수에 대한 원자 연산을 지원합니다. 휘발성 변수에 대한 읽기 및 쓰기처럼 작동하는 get 및 set 메서드가 있습니다. 즉, 세트는 동일한 변수에 대한 후속 get과 사전 발생 관계를 갖습니다. 원자 적 compareAndSet 메서드에는 이러한 메모리 일관성 기능도 있습니다.

AtomicInteger 메서드

다음은 AtomicInteger 클래스에서 사용할 수있는 중요한 메서드 목록입니다.

Sr. 아니.	방법 및 설명
1	public int addAndGet(int delta) 주어진 값을 현재 값에 원자 적으로 더합니다.
2	public boolean compareAndSet(int expect, int update) 현재 값이 예상 값과 같으면 원자 적으로 값을 지정된 업데이트 된 값으로 설정합니다.
삼	public int decrementAndGet() 원자 적으로 현재 값 1만큼 감소합니다.
4	public double doubleValue() 지정된 숫자의 값을 double로 반환합니다.
5	public float floatValue() 지정된 숫자의 값을 부동 소수점으로 반환합니다.
6	public int get() 현재 값을 가져옵니다.
7	public int getAndAdd(int delta) 주어진 값을 현재 값에 원자 적으로 더합니다.
8	public int getAndDecrement() 원자 적으로 현재 값 1만큼 감소합니다.
9	public int getAndIncrement() 현재 값을 원자 적으로 1 씩 증가시킵니다.
10	public int getAndSet(int newValue) 원자 적으로 주어진 값으로 설정하고 이전 값을 반환합니다.
11	public int incrementAndGet() 현재 값을 원자 적으로 1 씩 증가시킵니다.
12	public int intValue() 지정된 숫자의 값을 정수로 반환합니다.
13	public void lazySet(int newValue) 결국 주어진 값으로 설정됩니다.
14	public long longValue() 지정된 숫자의 값을 long으로 반환합니다.
15	public void set(int newValue) 주어진 값으로 설정합니다.
16	public String toString() 현재 값의 문자열 표현을 반환합니다.
17	public boolean weakCompareAndSet(int expect, int update) 현재 값이 예상 값과 같으면 원자 적으로 값을 지정된 업데이트 된 값으로 설정합니다.

예

다음 TestThread 프로그램은 스레드 기반 환경에서 안전하지 않은 카운터 구현을 보여줍니다.

public class TestThread {

   static class Counter {
      private int c = 0;

      public void increment() {
         c++;
      }

      public int value() {
         return c;
      }
   }
   
   public static void main(final String[] arguments) throws InterruptedException {
      final Counter counter = new Counter();
      
      //1000 threads
      for(int i = 0; i < 1000 ; i++) {
         
         new Thread(new Runnable() {
            
            public void run() {
               counter.increment();
            }
         }).start(); 
      }  
      Thread.sleep(6000);
      System.out.println("Final number (should be 1000): " + counter.value());
   }  
}

이것은 컴퓨터의 속도와 스레드 인터리빙에 따라 다음과 같은 결과를 생성 할 수 있습니다.

산출

Final number (should be 1000): 1000

예

다음 TestThread 프로그램은 스레드 기반 환경에서 AtomicInteger를 사용한 카운터의 안전한 구현을 보여줍니다.

import java.util.concurrent.atomic.AtomicInteger;

public class TestThread {

   static class Counter {
      private AtomicInteger c = new AtomicInteger(0);

      public void increment() {
         c.getAndIncrement();
      }

      public int value() {
         return c.get();
      }
   }
   
   public static void main(final String[] arguments) throws InterruptedException {
      final Counter counter = new Counter();
      
      //1000 threads
      for(int i = 0; i < 1000 ; i++) {

         new Thread(new Runnable() {
            public void run() {
               counter.increment();
            }
         }).start(); 
      }  
      Thread.sleep(6000);
      System.out.println("Final number (should be 1000): " + counter.value());
   }
}

그러면 다음과 같은 결과가 생성됩니다.

산출

Final number (should be 1000): 1000