읽기와 쓰기를 분리하는 Java 다중 스레드 readwritelock 예

이 글은 주로 Java 멀티스레딩의 readwritelock 분리 관련 내용을 소개합니다. 이 글에는 특정 참조 가치가 있는 특정 예제 코드가 포함되어 있습니다.

멀티 스레드 개발에서는 읽기와 쓰기를 분리하고 싶은 상황이 종종 있습니다. 읽기 작업의 경우 여러 스레드가 동시에 리소스를 읽을 수 있지만 쓰기 작업의 경우 하나의 스레드만 동시에 동작할 수 있으며 동시에 이를 동작시키는 쓰기 스레드가 있는 경우 리소스에 액세스할 때 , 다른 읽기 스레드는 이 리소스를 작동할 수 없습니다. 이는 멀티스레딩의 특성을 크게 극대화하고 멀티스레딩의 기능을 최대한 활용할 수 있습니다.

Java에서 ReadWriteLock 인터페이스는 ReentrantReadWriteLock 구현 클래스를 통해 이러한 요구 사항을 실현합니다. 이제 이 클래스의 사용법을 설명하기 위해 예제를 사용하겠습니다.

package com.bird.concursey.charpet3; 
import java.util.concurrent.locks.ReadWriteLock; 
import java.util.concurrent.locks.ReentrantReadWriteLock; 
public class PricesInfo { 
  private double price1; 
  private double price2; 
  private ReadWriteLock lock; 
  public PricesInfo() { 
    price1 = 1.0; 
    price2 = 2.0; 
    lock = new ReentrantReadWriteLock(); 
  } 
  public double getPrice1() { 
    //读取资源锁定 
    lock.readLock().lock(); 
    double value = price1; 
    lock.readLock().unlock(); 
    return value; 
  } 
  public double getPrice2() { 
    lock.readLock().lock(); 
    double value = price2; 
    lock.readLock().unlock(); 
    return value; 
  } 
  public void setPrices(double price1, double price2) { 
    lock.writeLock().lock(); 
    this.price1 = price1; 
    this.price2 = price2; 
    lock.writeLock().unlock(); 
  } 
}

다음은 읽기와 쓰기를 위한 두 가지 수업입니다

package com.bird.concursey.charpet3; 
public class Reader implements Runnable { 
  private PricesInfo pricesInfo; 
  public Reader(PricesInfo pricesInfo) { 
    this.pricesInfo = pricesInfo; 
  } 
  @Override 
  public void run() { 
    for (int i = 0; i < 10; i++) { 
      System.out.printf("%s: Price 1: %f\n", Thread.currentThread() 
          .getName(), pricesInfo.getPrice1()); 
      System.out.printf("%s: Price 2: %f\n", Thread.currentThread() 
          .getName(), pricesInfo.getPrice2()); 
    } 
  } 
}

package com.bird.concursey.charpet3; 
public class Writer implements Runnable { 
  private PricesInfo pricesInfo; 
  public Writer(PricesInfo pricesInfo) { 
    this.pricesInfo = pricesInfo; 
  } 
  @Override 
  public void run() { 
    for (int i = 0; i < 3; i++) { 
      System.out.printf("Writer: Attempt to modify the prices.\n"); 
      pricesInfo.setPrices(Math.random() * 10, Math.random( ) * 8); 
      System.out.printf("Writer: Prices have been modified.\n"); 
      try { 
        Thread.sleep(2); 
      } catch (InterruptedException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
  public static void main(String[] args) { 
    PricesInfo pricesInfo = new PricesInfo(); 
    Reader readers[] = new Reader[5]; 
    Thread threadsReader[] = new Thread[5]; 
    for (int i = 0; i < 5; i++){ 
      readers[i] = new Reader(pricesInfo); 
      threadsReader[i] = new Thread(readers[i]); 
    } 
    Writer writer = new Writer(pricesInfo); 
    Thread threadWriter = new Thread(writer); 
    for (int i = 0; i < 5; i++){ 
      threadsReader[i].start(); 
    } 
    threadWriter.start(); 
  } 
}

요약

위 내용은 읽기와 쓰기를 분리하는 Java 다중 스레드 readwritelock 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!