完成ReentrantReadWriteLock

Author: chenssy89

javaConcurrency/src/com/concurrency/ConcurrentHashMap/ConcurrentHashMapTest.java

@@ -0,0 +1,7 @@
+package com.concurrency.ConcurrentHashMap;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+public class ConcurrentHashMapTest {
+	private ConcurrentHashMap maps = new ConcurrentHashMap();
+}

javaConcurrency/src/com/concurrency/ReentrantReadWriteLock/PricesInfo.java

@@ -0,0 +1,39 @@
+package com.concurrency.ReentrantReadWriteLock;
+
+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();
+	}
+}

javaConcurrency/src/com/concurrency/ReentrantReadWriteLock/Reader.java

@@ -0,0 +1,19 @@
+package com.concurrency.ReentrantReadWriteLock;
+
+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.println(Thread.currentThread().getName() + "--Price 1:" + pricesInfo.getPrice1());
+			System.out.println(Thread.currentThread().getName() + "--Price 1:" + pricesInfo.getPrice2());
+		}
+	}
+
+}

javaConcurrency/src/com/concurrency/ReentrantReadWriteLock/TEst.java

@@ -0,0 +1,22 @@
+package com.concurrency.ReentrantReadWriteLock;
+
+public class Test {
+	public static void main(String[] args) {
+		PricesInfo pricesInfo = new PricesInfo();
+		
+		Reader[] readers = new Reader[5];
+		Thread[] readerThread = new Thread[5];
+		for (int i=0; i<5; i++){
+			readers[i]=new Reader(pricesInfo);
+			readerThread[i]=new Thread(readers[i]);
+		}
+		
+		Writer writer=new Writer(pricesInfo);
+		Thread threadWriter=new Thread(writer);
+		
+		for (int i=0; i<5; i++){
+			readerThread[i].start();
+		}
+		threadWriter.start();
+	}
+}

javaConcurrency/src/com/concurrency/ReentrantReadWriteLock/Test.java

@@ -0,0 +1,26 @@
+package com.concurrency.ReentrantReadWriteLock;
+
+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();
+			}
+		}
+		
+	}
+	
+	
+}