JDK5.0新特性系列---11.4线程 Condition
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
*有時候線程取得lock后需要在一定條件下才能做某些工作，比如經典的Producer和Consumer問題
*在Java 5.0以前，這種功能是由Object類的wait(),notify()和notifyAll()等方法實現的
*在5.0里面，這些功能集中到了Condition這個接口實現
*/
/**
* 使用Condition的關鍵技術點如下:
* 1.通過Lock的newCondition方法創建Condition的對象
* 2.Condition的await方法使當前線程進入等待狀態,并且釋放它占據的Lock,直到有其他的線程喚醒當前線程時,重新占有Lock.
* 3.Condition的signal方法喚醒其他正在等待該Condition的線程.
*/
public class ConditionTest {
/**
* 籃子程序，這里為了簡化問題，籃子中最多只能有一個蘋果
* Consumer必須在籃子里有蘋果的時候才能吃蘋果，否則它必須暫時放棄對籃子的鎖定
* 等到Producer往籃子里放了蘋果后再去拿來吃。
* 否則它也需要暫時解鎖等Comsumer把蘋果吃了才能往籃子里放蘋果。
*/
public static class Basket{
//鎖
Lock lock = new ReentrantLock();
//根據鎖產生Condition對象
Condition produced = lock.newCondition();
Condition consumed = lock.newCondition();
//籃子里的蘋果數，最多為1
int num = 0;
//生產蘋果，往籃子里放
public void produce() throws InterruptedException{
//獲得鎖
lock.lock();
System.out.println("Producer get a lock...");
try{
//判斷是否滿足生產條件
while(num == 1){
//如果有蘋果，則不生產，放棄鎖，進入睡眠
//等待消費者消費
System.out.println("Producer sleep...");
consumed.await();
System.out.println("Producer awaked...");
}
//生產蘋果
Thread.sleep(500);
System.out.println("Producer produced an Apple.");
num = 1;
//通知等待produced Condition的線程
produced.signal();
}finally{
lock.unlock();
}
}
//消費蘋果，從籃子里取
public void consume() throws InterruptedException{
//獲得鎖
lock.lock();
System.out.println("Consumer get a lock...");
try{
//判斷是否滿足消費條件
while(num == 0){
//如果沒有蘋果，無法消費，則放棄鎖，進入睡眠
//等待生產者生產蘋果
System.out.println("Consumer sleep...");
produced.await();
System.out.println("Consumer awaked...");
}
//吃蘋果
Thread.sleep(500);
System.out.println("Consumer consumed an Apple.");
num = 0;
//發信號喚醒某個等待consumed Condition的線程
consumed.signal();
} finally {
lock.unlock();
}
}
}
//測試Basket程序
public static void testBasket() throws Exception{
final Basket basket = new Basket();
//定義一個producer
Runnable producer = new Runnable(){
public void run() {
try{
basket.produce();
}catch(InterruptedException ex){
ex.printStackTrace();
}
}
};
//定義一個consumer
Runnable consumer = new Runnable(){
public void run(){
try{
basket.consume();
}catch(InterruptedException ex){
ex.printStackTrace();
}
}
};
//各生產3個consumer和producer
ExecutorService service = Executors.newCachedThreadPool();
for(int i = 0; i <3; i++){
service.submit(producer);
}
for(int i = 0;i<3;i++){
service.submit(consumer);
}
service.shutdown();
}
public static void main(String... args)throws Exception{
ConditionTest.testBasket();
}
}
本文轉自遠哥博客園博客，原文鏈接：http://www.cnblogs.com/taven/archive/2011/12/17/2291471.html，如需轉載請自行聯系原作者
總結
以上是生活随笔為你收集整理的JDK5.0新特性系列---11.4线程 Condition的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： ubuntu下用apt-get安装软件时
- 下一篇： 从头写个http client（java