Java 다중 스레드 프로그래밍 읽기-쓰기 잠금 ReadWriteLock 사용 예

읽기-쓰기 잠금: 읽기 잠금과 쓰기 잠금으로 구분됩니다. 다중 읽기 잠금은 상호 배타적이지 않습니다. 이는 jvm 자체에 의해 제어됩니다. 잠그다. 코드가 데이터를 읽기만 하고 많은 사람이 동시에 읽을 수 있지만 동시에 쓸 수 없는 경우, 코드가 데이터를 수정하면 한 사람만 쓸 수 있지만 동시에 읽을 수는 없습니다. 그런 다음 쓰기 잠금을 적용합니다. 즉, 읽을 때는 읽기 잠금을 사용하고, 쓸 때는 쓰기 잠금을 사용하는 것입니다!

3개의 스레드가 데이터를 읽고 3개의 스레드가 데이터를 씁니다. 예:
동시에 읽을 수 있고, 읽는 동안 쓸 수 없으며, 동시에 쓸 수 없으며, 쓰는 동안 읽을 수 없습니다.
읽을 때는 읽기 잠금이 설정되고, 읽은 후에는 잠금이 해제되고, 쓸 때는 쓰기 잠금이 설정되고, 쓴 후에 잠금이 해제됩니다.
드디어 잠금이 해제되었으니 참고하세요.

package com.ljq.test.thread;
  
import java.util.Random;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
  
/**
 * 读写锁
 *
 * @author Administrator
 *
 */
public class ReadWriteLockTest {
  public static void main(String[] args) {
    final ReadWrite rw = new ReadWrite();
    for (int i = 0; i < 3; i++) {
      new Thread() {
        public void run() {
          while (true) {
            rw.read();
          }
        }
  
      }.start();
  
      new Thread() {
        public void run() {
          while (true) {
            rw.write(new Random().nextInt(10000));
          }
        }
  
      }.start();
    }
  
  }
}
  
/**
 * 读和写要互斥，因此要把它们放在同一个类中
 *
 * @author Administrator
 *
 */
class ReadWrite {
  private Object data = null;//共享数据，只能有一个线程写该数据，但可以有多个线程同时读该数据。
  ReadWriteLock rwl = new ReentrantReadWriteLock();
  
  /**
   * 读数据
   */
  public void read() {
      
    rwl.readLock().lock();
    try {
      System.out.println(Thread.currentThread().getName() + " be ready to read data!");
      Thread.sleep((long) (Math.random() * 1000));
      System.out.println(Thread.currentThread().getName() + "have read data :" + data);
    } catch (InterruptedException e) {
      e.printStackTrace();
    } finally {
      rwl.readLock().unlock();
    }
      
  }
  
  /**
   * 写数据
   *
   * @param data
   */
  public void write(Object data) {
      
    rwl.writeLock().lock();
    try {
      System.out.println(Thread.currentThread().getName() + " be ready to write data!");
      Thread.sleep((long) (Math.random() * 1000));
      this.data = data;
      System.out.println(Thread.currentThread().getName() + " have write data: " + data);
    } catch (InterruptedException e) {
      e.printStackTrace();
    } finally {
      rwl.writeLock().unlock();
    }
  
  }
}

캐시 시스템 설계
캐시 시스템: 데이터를 가져오려면 공개 객체 getData(String key) 메서드를 호출해야 합니다. 이 데이터가 내부적으로 있는지 확인하고 싶습니다. 그렇다면 직접 반환하고, 그렇지 않으면 데이터베이스에서 번호를 검색한 후 내 내부 메모리에 데이터를 저장합니다. 데이터베이스에 있습니다. 데이터를 얻고 싶다면 데이터베이스를 찾지 말고 나에게로 오세요.

package com.ljq.test.thread;
  
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
  
/**
 * 设计一个缓存系统
 *
 *
 * @author Administrator
 *
 */
public class CacheDemo {
  
  private Map<String, Object> cache = new HashMap<String, Object>();
  
  public static void main(String[] args) {
    String key = "name";
    CacheDemo cacheDemo = new CacheDemo();
    System.out.println(cacheDemo.getData(key)); //从数据库获取数据
    System.out.println(cacheDemo.getData(key)); //从缓存获取数据
    System.out.println(cacheDemo.getData(key)); //从缓存获取数据
  }
  
  private ReadWriteLock rwl = new ReentrantReadWriteLock();
  
  public Object getData(String key) {
    rwl.readLock().lock(); //上读锁
    Object value = null;
    try {
      value = cache.get(key); //先查询内部存储器中有没有要的值
      if (value == null) { //如果没有，就去数据库中查询，并将查到的结果存入内部存储器中
        //释放读锁、上写锁
        rwl.readLock().unlock();
        rwl.writeLock().lock();
        try {
          if (value == null) { //再次进行判断，防止多个写线程堵在这个地方重复写
            System.out.println("read data from database");
            value = "张三";
            cache.put(key, value);
          }
        } finally {
          //设置完成 释放写锁
          rwl.writeLock().unlock();
        }
        //恢复读写状态
        rwl.readLock().lock();
      }else{
        System.out.println("read data from cache");
      }
    } finally {
      rwl.readLock().unlock(); //释放读锁
    }
    return value;
  }
}

더 많은 Java 다중 스레드 프로그래밍 읽기-쓰기 잠금 ReadWriteLock 사용 예제 관련 기사를 보려면 PHP 중국어 웹사이트에 주목하세요!