keep moving!

JAVA后臺(tái)程序設(shè)計(jì)及UTIL.CONCURRENT包的應(yīng)用

回復(fù)(1):

4.2　　　　框架與結(jié)構(gòu)
下面讓我們來看看util.concurrent的框架結(jié)構(gòu)。關(guān)于這個(gè)工具包概述的e文原版鏈接地址是http: //gee.cs.oswego.edu/dl/cpjslides/util.pdf。該工具包主要包括三大部分：同步、通道和線程池執(zhí)行器。第一部分 主要是用來定制鎖，資源管理，其他的同步用途；通道則主要是為緩沖和隊(duì)列服務(wù)的；線程池執(zhí)行器則提供了一組完善的復(fù)雜的線程池實(shí)現(xiàn)。
--主要的結(jié)構(gòu)如下圖所示

4.2.1 Sync
acquire/release協(xié)議的主要接口
- 用來定制鎖，資源管理，其他的同步用途
- 高層抽象接口
- 沒有區(qū)分不同的加鎖用法

實(shí)現(xiàn)
-Mutex, ReentrantLock, Latch, CountDown,Semaphore, WaiterPreferenceSemaphore, FIFOSemaphore, PrioritySemaphore
還有，有幾個(gè)簡(jiǎn)單的實(shí)現(xiàn)，例如ObservableSync, LayeredSync

舉例：如果我們要在程序中獲得一獨(dú)占鎖，可以用如下簡(jiǎn)單方式：
try {
lock.acquire();
try {
action();
}
finally {
lock.release();
}
}catch（Exception e）{
}

程序中,使用lock對(duì)象的acquire()方法獲得一獨(dú)占鎖，然后執(zhí)行您的操作，鎖用完后，使用release()方法釋放之即可。呵呵，簡(jiǎn)單吧，想 想看，如果您親自撰寫?yīng)氄兼i，大概會(huì)考慮到哪些問題？如果關(guān)鍵的鎖得不到怎末辦？用起來是不是會(huì)復(fù)雜很多？而現(xiàn)在，以往的很多細(xì)節(jié)和特殊異常情況在這里都 無需多考慮，您盡可以把精力花在解決您的應(yīng)用問題上去。

4.2.2 通道(Channel)
為緩沖，隊(duì)列等服務(wù)的主接口

具體實(shí)現(xiàn)
LinkedQueue, BoundedLinkedQueue,BoundedBuffer, BoundedPriorityQueue, SynchronousChannel, Slot

通道例子
class Service { // ...
final Channel msgQ = new LinkedQueue();
public void serve() throws InterruptedException {
String status = doService();
msgQ.put(status);
}
public Service() { // start background thread
Runnable logger = new Runnable() {
public void run() {
try {
for(;;)
System.out.println(msqQ.take());
}
catch(InterruptedException ie) {} }
};
new Thread(logger).start();
}
}
在后臺(tái)服務(wù)器中，緩沖和隊(duì)列都是最常用到的。試想，如果對(duì)所有遠(yuǎn)端的請(qǐng)求不排個(gè)隊(duì)列，讓它們一擁而上的去爭(zhēng)奪cpu、內(nèi)存、資源，那服務(wù)器瞬間不當(dāng)?shù)舨殴帧６谶@里，成熟的隊(duì)列和緩沖實(shí)現(xiàn)已經(jīng)提供，您只需要對(duì)其進(jìn)行正確初始化并使用即可，大大縮短了開發(fā)時(shí)間。

4.2.3執(zhí)行器(Executor)
Executor是這里最重要、也是我們往往最終寫程序要用到的，下面重點(diǎn)對(duì)其進(jìn)行介紹。
類似線程的類的主接口
- 線程池
- 輕量級(jí)運(yùn)行框架
- 可以定制調(diào)度算法

只需要支持execute(Runnable r)
- 同Thread.start類似

實(shí)現(xiàn)
- PooledExecutor, ThreadedExecutor, QueuedExecutor, FJTaskRunnerGroup

PooledExecutor（線程池執(zhí)行器）是個(gè)最常用到的類，以它為例：
可修改得屬性如下：
- 任務(wù)隊(duì)列的類型
- 最大線程數(shù)
- 最小線程數(shù)
- 預(yù)熱(預(yù)分配)和立即(分配)線程
- 保持活躍直到工作線程結(jié)束
-- 以后如果需要可能被一個(gè)新的代替
- 飽和(Saturation)協(xié)議
-- 阻塞，丟棄，生產(chǎn)者運(yùn)行，等等

可不要小看上面這數(shù)條屬性，對(duì)這些屬性的設(shè)置完全可以等同于您自己撰寫的線程池的成百上千行代碼。下面以筆者撰寫過得一個(gè)GIS服務(wù)器為例：
該GIS服務(wù)器是一個(gè)典型的“請(qǐng)求－服務(wù)”類型的服務(wù)器，遵循后端程序設(shè)計(jì)的一般框架。首先對(duì)所有的請(qǐng)求按照先來先服務(wù)排入一個(gè)請(qǐng)求隊(duì)列，如果瞬間到達(dá)的 請(qǐng)求超過了請(qǐng)求隊(duì)列的容量，則將溢出的請(qǐng)求轉(zhuǎn)移至一個(gè)臨時(shí)隊(duì)列。如果臨時(shí)隊(duì)列也排滿了，則對(duì)以后達(dá)到的請(qǐng)求給予一個(gè)“服務(wù)器忙”的提示后將其簡(jiǎn)單拋棄。這 個(gè)就夠忙活一陣的了。
然后，結(jié)合鏈表結(jié)構(gòu)實(shí)現(xiàn)一個(gè)線程池，給池一個(gè)初始容量。如果該池滿，以x2的策略將池的容量動(dòng)態(tài)增加一倍，依此類推，直到總線程數(shù)服務(wù)達(dá)到系統(tǒng)能力上限， 之后線程池容量不在增加，所有請(qǐng)求將等待一個(gè)空余的返回線程。每從池中得到一個(gè)線程，該線程就開始最請(qǐng)求進(jìn)行GIS信息的服務(wù)，如取坐標(biāo)、取地圖，等等。 服務(wù)完成后，該線程返回線程池繼續(xù)為請(qǐng)求隊(duì)列離地后續(xù)請(qǐng)求服務(wù)，周而復(fù)始。當(dāng)時(shí)用矢量鏈表來暫存請(qǐng)求，用wait()、 notify() 和 synchronized等原語結(jié)合矢量鏈表實(shí)現(xiàn)線程池，總共約600行程序，而且在運(yùn)行時(shí)間較長(zhǎng)的情況下服務(wù)器不穩(wěn)定，線程池被取用的線程有異常消失的 情況發(fā)生。而使用util.concurrent相關(guān)類之后，僅用了幾十行程序就完成了相同的工作而且服務(wù)器運(yùn)行穩(wěn)定，線程池沒有丟失線程的情況發(fā)生。由 此可見util.concurrent包極大的提高了開發(fā)效率，為項(xiàng)目節(jié)省了大量的時(shí)間。
使用PooledExecutor例子
import java.net.*;
/**
* Title:
* Description: 負(fù)責(zé)初始化線程池以及啟動(dòng)服務(wù)器
* Copyright: Copyright (c) 2003
* Company:
* @author not attributable
* @version 1.0
*/
public class MainServer {
//初始化常量
public static final int MAX_CLIENT=100; //系統(tǒng)最大同時(shí)服務(wù)客戶數(shù)
//初始化線程池
public static final PooledExecutor pool =
new PooledExecutor(new BoundedBuffer(10), MAX_CLIENT); //chanel容量為10,
//在這里為線程池初始化了一個(gè)
//長(zhǎng)度為10的任務(wù)緩沖隊(duì)列。

public MainServer() {
//設(shè)置線程池運(yùn)行參數(shù)
pool.setMinimumPoolSize(5); //設(shè)置線程池初始容量為5個(gè)線程
pool.discardOldestWhenBlocked();//對(duì)于超出隊(duì)列的請(qǐng)求，使用了拋棄策略。
pool.createThreads(2); //在線程池啟動(dòng)的時(shí)候，初始化了具有一定生命周期的2個(gè)“熱”線程
}

public static void main(String[] args) {
MainServer MainServer1 = new MainServer();
new HTTPListener().start();//啟動(dòng)服務(wù)器監(jiān)聽和處理線程
new manageServer().start();//啟動(dòng)管理線程
}
}



類HTTPListener
import java.net.*;
/**
* Title:
* Description: 負(fù)責(zé)監(jiān)聽端口以及將任務(wù)交給線程池處理
* Copyright: Copyright (c) 2003
* Company:
* @author not attributable
* @version 1.0
*/
public class HTTPListener extends Thread{
public HTTPListener() {
}
public void run(){
try{
ServerSocket server=null;
Socket clientconnection=null;
server = new ServerSocket(8008);//服務(wù)套接字監(jiān)聽某地址端口對(duì)
while(true){//無限循環(huán)
clientconnection =server.accept();
System.out.println("Client connected in!");
//使用線程池啟動(dòng)服務(wù)
MainServer.pool.execute(new HTTPRequest(clientconnection));//如果收到一個(gè)請(qǐng)求，則從線程池中取一個(gè)線程進(jìn)行服務(wù)，任務(wù)完成后，該線程自動(dòng)返還線程池
}
}catch(Exception e){
System.err.println("Unable to start serve listen:"+e.getMessage());
e.printStackTrace();
}
}
}

關(guān)于util.concurrent工具包就有選擇的介紹到這，更詳細(xì)的信息可以閱讀這些java源代碼的API文檔。Doug Lea是個(gè)很具有“open”精神的作者，他將util.concurrent工具包的java源代碼全部公布出來，有興趣的讀者可以下載這些源代碼并細(xì) 細(xì)品味。

5　　　　結(jié)束語
以上內(nèi)容介紹了線程池基本原理以及設(shè)計(jì)后臺(tái)服務(wù)程序應(yīng)考慮到的問題，并結(jié)合實(shí)例詳細(xì)介紹了重要的多線程開發(fā)工具包util.concurrent的構(gòu)架和使用。結(jié)合使用已有完善的開發(fā)包，后端服務(wù)程序的開發(fā)周期將大大縮短，同時(shí)程序性能也有了保障。



參考文獻(xiàn)
[1] Chad Darby,etc. 《Beginning Java Networking》. 電子工業(yè)出版社. 2002年3月.
[2] util.concurrent 說明文件 http://gee.cs.oswego.edu/dl/cpjslides/util.pdf
[3] 幸勇.線程池的介紹及簡(jiǎn)單實(shí)現(xiàn).http://www-900.ibm.com/developerWorks/cn/java/l-threadPool/index.shtml
2002年8月
[4]BrianGoetz. 我的線程到哪里去了http://www-900.cn.ibm.com/developerworks/cn/java/j-jtp0924/index.shtml