编写多线程Java应用程序并不是小菜一碟。 必须格外小心，因为同步不良会使您的应用程序一s不振。 JVM堆由所有线程共享。 如果多个线程需要同时使用相同的对象或静态类变量，则必须谨慎管理对共享数据的线程访问。 从1.5版开始，JSDK中包含了在并发编程中通常有用的实用程序类。

在Java中， sync关键字用于获取对象的排他锁。 当线程获取对象的锁以进行读取或写入时，其他线程必须等待，直到该对象的锁被释放。 想想一个场景，有许多读取器线程经常读取共享数据，而只有一个写入器线程更新共享数据。 读取时不必排他地锁定对共享数据的访问，因为除非有写入操作，否则可以并行执行多个读取操作。

在本文中，我将提供Java 1.5 API文档中引入的ReadWriteLock接口的示例用法。 在Java Api文档中，它说：

ReadWriteLock维护一对关联的锁，
一种用于只读操作，另一种用于写操作。
读取锁可以由多个读取器线程同时保持，
只要没有作家。 写锁是排他的。

读取器线程可以同时读取共享数据。 读取操作不会阻止其他读取操作。 执行SQL SELECT语句时就是这种情况。 但是写操作是排他的。 这意味着当写入器线程持有用于修改共享数据的锁时，所有读取器和其他写入器均被阻止。

Writer.java此类表示更新共享数据的线程。 Writer使用ReadWriteLock的WriteLock专门锁定对字典的访问。

package deneme.readwritelock;public class Writer extends Thread{private boolean runForestRun = true;private Dictionary dictionary = null;public Writer(Dictionary d, String threadName) {this.dictionary = d;this.setName(threadName);}@Overridepublic void run() {while (this.runForestRun) { String [] keys = dictionary.getKeys();for (String key : keys) {String newValue = getNewValueFromDatastore(key);//updating dictionary with WRITE LOCKdictionary.set(key, newValue);}//update every secondstry {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}public void stopWriter(){this.runForestRun = false;this.interrupt();}public String getNewValueFromDatastore(String key){//This part is not implemented. Out of scope of this artilereturn "newValue";}}

Reader.java此类表示读取共享数据的线程。

package deneme.readwritelock;public class Reader extends Thread{private Dictionary dictionary = null;public Reader(Dictionary d, String threadName) {this.dictionary = d;this.setName(threadName);}private boolean runForestRun = true;@Overridepublic void run() {while (runForestRun) {String [] keys = dictionary.getKeys();for (String key : keys) {//reading from dictionary with READ LOCKString value = dictionary.get(key);//make what ever you want with the value.System.out.println(key + " : " + value);}//update every secondstry {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}public void stopReader(){this.runForestRun = false;this.interrupt();}}

Dictionary.java这是一个简单且线程安全的字典。 读操作通过ReadLock进行管理，写操作（更新）通过WriteLock进行管理。

package deneme.readwritelock;import java.util.HashMap;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantReadWriteLock;public class Dictionary {private final ReentrantReadWriteLock readWriteLock = new ReentrantReadWriteLock();private final Lock read  = readWriteLock.readLock();private final Lock write = readWriteLock.writeLock();private HashMap<String, String> dictionary = new HashMap<String, String>();public void set(String key, String value) {write.lock();try {dictionary.put(key, value);} finally {write.unlock();}}public String get(String key) {read.lock();try{return dictionary.get(key);} finally {read.unlock();}}public String[] getKeys(){read.lock();try{String keys[] = new String[dictionary.size()];return dictionary.keySet().toArray(keys);} finally {read.unlock();}}public static void main(String[] args) {Dictionary dictionary = new Dictionary();dictionary.set("java",  "object oriented");dictionary.set("linux", "rulez");Writer writer  = new Writer(dictionary, "Mr. Writer");Reader reader1 = new Reader(dictionary ,"Mrs Reader 1");Reader reader2 = new Reader(dictionary ,"Mrs Reader 2");Reader reader3 = new Reader(dictionary ,"Mrs Reader 3");Reader reader4 = new Reader(dictionary ,"Mrs Reader 4");Reader reader5 = new Reader(dictionary ,"Mrs Reader 5");writer.start();reader1.start();reader2.start();reader3.start();reader4.start();reader5.start();}}

参考：来自我们的JCG合作伙伴 Ilkin Ulas的Java中的ReadWriteLock示例， 您的所有博客都属于我们博客。