Java 동시 프로그래밍의 휘발성 키워드 소개(예제 포함)

이 글은 Java 동시 프로그래밍의 휘발성 키워드에 대한 소개를 제공합니다(예제 포함). 필요한 친구가 참고할 수 있기를 바랍니다.

휘발성-설명

• 휘발성 키워드의 역할은 변수가 여러 스레드에서 표시된다는 것입니다.

• 휘발성 키워드는 비원자적입니다.

• 원자적 연산을 구현하려면 다음을 수행하는 것이 좋습니다. 원자 클래스의 일련의 객체 사용: 원자 작업을 지원합니다(원자 클래스는 자체 메서드의 원자성만 보장하며 여러 작업의 원자성은 보장하지 않습니다)

1 휘발성 :

• 휘발성 키워드의 역할은 변수를 여러 스레드에서 사용할 수 있다는 것입니다. Visible;

예: RunThread.java
설명: Java에서는 각 스레드에 귀중한 복사본을 저장하는 작업 메모리 영역이 있습니다. 모든 스레드가 공유하는 주 메모리의 변수 중 하나입니다. 스레드가 실행되면 이러한 변수는 자체 작업 메모리 영역에서 조작됩니다. 공유 변수에 접근하기 위해 스레드는 일반적으로 먼저 잠금을 획득하고 현재 스레드의 메모리 작업 영역을 지운 다음 모든 스레드의 공유 메모리 영역에서 자체 작업 메모리 영역으로 이러한 공유 변수를 올바르게 로드합니다. 작업 메모리에 있는 변수의 값이 공유 메모리 영역에 쓰여지는 것입니다.

• * 스레드가 수행할 수 있는 작업은 사용(use), 할당(assgin), 로드(load), 저장(store), 잠금(lock), 잠금 해제(unlock)입니다. 메모리 수행할 수 있는 작업은 다음과 같습니다. 읽기, 쓰기, 잠금 및 잠금 해제 각 작업은 원자적입니다.

• * 휘발성의 기능은 스레드가 스레드의 작업 메모리 영역에서 변수를 읽는 대신 주 메모리(공유 메모리)에서 변수를 읽도록 강제하여 여러 스레드 간에 변수가 표시되도록 하는 것입니다. 이는 스레드 안전 가시성도 충족합니다.

• public class RunThread extends Thread{
  
      private volatile boolean isRunning = true;
      private void setRunning(boolean isRunning){
          this.isRunning = isRunning;
      }
  
      public void run(){
          System.out.println("进入run方法..");
          int i = 0;
          while(isRunning == true){
              //..
          }
          System.out.println("线程停止");
      }
  
      public static void main(String[] args) throws InterruptedException {
          RunThread rt = new RunThread();
          rt.start();
          Thread.sleep(1000);
          rt.setRunning(false);
          System.out.println("isRunning的值已经被设置了false");
      }
  }

  2. 휘발성 키워드는 비원자적입니다.

휘발성 키워드는 여러 스레드 간에 가시성을 가지지만 동기화(즉, 원자성)가 없지만 간주될 수 있습니다. 경량 동기화로서 성능은 동기화보다 훨씬 좋으며 차단을 유발하지 않습니다(많은 오픈 소스 아키텍처에서 netty의 기본 코드는 휘발성이므로 netty의 성능을 보여줍니다)

* 비용을 지불해야 함 주의 사항: 일반적으로 휘발성은 여러 스레드에 표시되는 변수 작업에 사용되며 동기화 효과를 대체할 수 없습니다.

• 예: 동시.java

설명: 휘발성 키워드에는 가시성만 있고 원자 섹스는 없습니다. .

import java.util.concurrent.atomic.AtomicInteger;
/**
* volatile关键字不具备synchronized关键字的原子性（同步）
* @@author Maozw
*
*/
public class VolatileNoAtomic extends Thread{
    //private static volatile int count;
    private static AtomicInteger count = new AtomicInteger(0);
    private static void addCount(){
      for (int i = 0; i < 1000; i++) {
        //count++ ;
        count.incrementAndGet();
      }
      System.out.println(count);
    }

    public void run(){
      addCount();
    }

    public static void main(String[] args) {

      VolatileNoAtomic[] arr = new VolatileNoAtomic[100];
      for (int i = 0; i < 10; i++) {
        arr[i] = new VolatileNoAtomic();
      }

      for (int i = 0; i < 10; i++) {
        arr[i].start();
      }
    }
}

* 원자 연산을 구현하려면 원자 클래스의 일련의 객체를 사용하는 것이 좋습니다. 원자 연산을 지원합니다(원자 클래스는 자체 메서드의 원자성만 보장할 뿐, 원자성을 보장하지는 않습니다). 다중 연산의 원자성)

• 예:

설명:

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

public class AtomicUse {

private static AtomicInteger count = new AtomicInteger(0);

    //多个addAndGet在一个方法内是非原子性的，需要加synchronized进行修饰，保证4个addAndGet整体原子性
    /**synchronized*/
    public synchronized int multiAdd(){
        try {
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        count.addAndGet(1);
        count.addAndGet(2);
        count.addAndGet(3);
        count.addAndGet(4); //+10
        return count.get();
    }
    public static void main(String[] args) {

      final AtomicUse au = new AtomicUse();

      List<Thread> ts = new ArrayList<Thread>();
      for (int i = 0; i < 100; i++) {
        ts.add(new Thread(new Runnable() {
          @Override
          public void run() {
            System.out.println(au.multiAdd());
          }
        }));
      }
      for(Thread t : ts){
        t.start();
      }
    }
}

위 내용은 Java 동시 프로그래밍의 휘발성 키워드 소개(예제 포함)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!