需要注意的是ReadWriteLock提供了一個(gè)高效的鎖定機(jī)理，但最終程序的運(yùn)行效率是和程序的設(shè)計(jì)息息相關(guān)的，比如說如果讀的線程和寫的線程同時(shí)在等待，要考慮是先發(fā)放讀的lock還是先發(fā)放寫的lock。如果寫發(fā)生的頻率不高，而且快，可以考慮先給寫的lock。還要考慮的問題是如果一個(gè)寫正在等待讀完成，此時(shí)一個(gè)新的讀進(jìn)來，是否要給這個(gè)新的讀發(fā)鎖，如果發(fā)了，可能導(dǎo)致寫的線程等很久。等等此類問題在編程時(shí)都要給予充分的考慮。
Condition接口：
有時(shí)候線程取得lock后需要在一定條件下才能做某些工作，比如說經(jīng)典的Producer和Consumer問題，Consumer必須在籃子里有蘋果的時(shí)候才能吃蘋果，否則它必須暫時(shí)放棄對(duì)籃子的鎖定，等到Producer往籃子里放了蘋果后再去拿來吃。而Producer必須等到籃子空了才能往里放蘋果，否則它也需要暫時(shí)解鎖等Consumer把蘋果吃了才能往籃子里放蘋果。在Java 5.0以前，這種功能是由Object類的wait(), notify()和notifyAll()等方法實(shí)現(xiàn)的，在5.0里面，這些功能集中到了Condition這個(gè)接口來實(shí)現(xiàn)，Condition提供以下方法：
await()：使調(diào)用此方法的線程放棄鎖定，進(jìn)入睡眠直到被打斷或被喚醒。
signal(): 喚醒一個(gè)等待的線程
signalAll()：?jiǎn)拘阉械却木�程
Condition的例子：
public class Basket {
Lock lock = new ReentrantLock();
//產(chǎn)生Condition對(duì)象
Condition produced = lock.newCondition();
Condition consumed = lock.newCondition();
boolean available = false;
public void produce() throws InterruptedException {
lock.lock();
try {
if(available){
consumed.await(); //放棄lock進(jìn)入睡眠
}
/*生產(chǎn)蘋果*/
System.out.println("Apple produced.");
available = true;
produced.signal(); //發(fā)信號(hào)喚醒等待這個(gè)Condition的線程
} finally {
lock.unlock();
}
}
public void consume() throws InterruptedException {
lock.lock();
try {
if(!available){
produced.await();//放棄lock進(jìn)入睡眠
}
/*吃蘋果*/
System.out.println("Apple consumed.");
available = false;
consumed.signal();//發(fā)信號(hào)喚醒等待這個(gè)Condition的線程
} finally {
lock.unlock();
}
}
}
ConditionTester:
public class ConditionTester {
public static void main(String[] args) throws InterruptedException{
final Basket basket = new Basket();
//定義一個(gè)producer
Runnable producer = new Runnable() {
public void run() {
try {
basket.produce();
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
};
//定義一個(gè)consumer
Runnable consumer = new Runnable() {
public void run() {
try {
basket.consume();
} catch (InterruptedException ex) {
ex.printStackTrace();
}
}
};
//各產(chǎn)生10個(gè)consumer和producer
ExecutorService service = Executors.newCachedThreadPool();
for(int i=0; i < 10; i++)
service.submit(consumer);
Thread.sleep(2000);
for(int i=0; i<10; i++)
service.submit(producer);
service.shutdown();
}
}
相關(guān)推薦：計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總| 北京 | 天津 | 上海 | 江蘇 | 山東 |
| 安徽 | 浙江 | 江西 | 福建 | 深圳 |
| 廣東 | 河北 | 湖南 | 廣西 | 河南 |
| 海南 | 湖北 | 四川 | 重慶 | 云南 |
| 貴州 | 西藏 | 新疆 | 陜西 | 山西 |
| 寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
| 黑龍江 | 內(nèi)蒙古 |
