ホームページ >Java >&#&チュートリアル >Java マルチスレッド readwritelock の読み取りと書き込みの分離の例
この記事では主に Java マルチスレッドの readwritelock 分離に関連する内容を紹介します。この記事には具体的なコード例が含まれており、必要な方はそれについて学ぶことができます。
マルチスレッド開発では、読み取りと書き込みを分離したい状況がよくあります。読み取りアクションの場合、複数のスレッドが同時にリソースを読み取ることができますが、書き込みアクションの場合、同時に動作できるスレッドは 1 つだけであり、同時にこれを操作する書き込みスレッドが存在する場合、リソースにアクセスするとき、他の読み取りスレッドはこのリソースを操作できません。これにより、マルチスレッドの特性が最大限に活用され、マルチスレッドの機能を最大限に活用できます。
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(); } }
以下は、読み書きのための 2 つの異なるクラスです
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 中国語 Web サイトの他の関連記事を参照してください。