日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > java >内容正文

java

java j2se1.5_Java教程 用J2SE1.5建立多任务的Java应用程序

發布時間:2025/3/15 java 16 豆豆
生活随笔 收集整理的這篇文章主要介紹了 java j2se1.5_Java教程 用J2SE1.5建立多任务的Java应用程序 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

Future和FutureTask

在Java的早期版本中,查詢運行中的線程狀態,以及使線程在執行之后返回一個值是非常困難的。由于run(運行)方法返回void,你必須編寫大量的代碼從線程中返回一個值。使用過這種方法的程序員肯定了解其痛苦的經歷。

你可以使用Future接口或者FutureTask類從異步執行的線程中得到一個返回值。Future接口提供了檢查計算過程是否完成、檢索計算結果或終止計算過程的一些方法。FutureTask類提供了Future接口方法的基本實現(implementation)。只有計算過程完成以后才能檢索結果;如果計算過程沒有完成,get方法會被阻塞(block)。

下載代碼中的MyStringReverser.java文件演示了FutureTask類的使用,并提供了一個容易理解的示例。它以每秒鐘一個字符的速度從后向前顯示提交的字符串,同時主線程檢測事務是否完成了:

while(!future.isDone()){

System.out.println("Task not yet completed.");

try{

Thread.currentThread().sleep(500);

}catch(InterruptedException ie){

System.out.println("Will check after 1/2 sec.");

}

}

在事務完成以后,就使用get方法從Future對象中檢索結果:

System.out.println("Here is result..."+future.get());

ThreadPoolExecutor(線程池執行器)

有了ThreadPoolExecutor類之后你可以編寫自己的服務器了。這個類為配置和調整服務器提供了很多的特性,與很多大規模的企業級EJB服務器相似。下面是它的一些配置參數:

? 核心和最大的線程池大小

通過把corePoolSize和maximumPoolSize設置為相同的值,你就可以建立一個大小固定的線程池了。通過把maximumPoolSize設置為一個極大的值(例如Integer.MAX_VALUE),你就可以允許線程池容納任意數量的并發事務了。

? 根據需要構造

在默認情況下,只有在新事務要求的時候,ThreadPoolExecutor才開始建立和啟動核心的線程,但是你可以使用prestartCoreThread或prestartAllCoreThreads動態地重載它。

? 保持活動的時間

如果線程池中當前線程的數量超過了corePoolSize,那么這些超過的線程的空閑時間大于keepAliveTime的時候,它們就會被終止。

? 排隊

排隊遵循下面的規則:

? 如果正在運行的線程數量少于corePoolSize,Executor總會添加新線程而不會排隊。

? 如果corePoolSize或更多數量的線程在運行,Executor總會對請求進行排隊而不會添加新線程。

? 如果某個請求不能參與排隊,就會建立新線程,除非線程數量超過了maximumPoolSize(在超過的情況下,該事務會被拒絕)。

? Hook方法

這個類提供了beforeExecute()和afterExecute() hook方法,它們分別在每個事務執行之前和之后被調用。為了使用它們,你必須建立這個類的子類(因為這些方法是受保護的)。

下載代碼中的MyThreadPoolExecutor.java提供了一些監視多種配置參數的詳細示例。你可以發現隨著每個事務的增加和完成,線程池和隊列大小在不斷變化。你可以修改代碼中的設置信息。 并發集合

JDK 1.5提供了下面一些集合實現,它們是被設計為用于多線程環境的:

? ConcurrentHashMap

? CopyOnWriteArrayList

? CopyOnWriteArraySet

ConcurrentHashMap類為檢索和更新(update)可調整的預期的并發性提供了完整的線程安全的(thread-safe)并發性支持。CopyOnWriteArraySet是一組線程安全的變量集合,CopyOnArrayList是一個線程安全的數組列表(ArrayList)變量。在修改原始的數組或集合之前,它們中的每一個都會把下層的數組或集合復制一份。其結果是,讀取的速度很快,而更新的速度很慢。

并發集合類為Iterator(迭代子)提供快照式的數據(即使下層數據發生了改變,在Iterator中也不會反映出來)。

同步器(Synchronizer)

JDK 1.5還提供了一些高級類,例如Semaphore、CountDownLatch和CyclicBarrier,還有一個用于同步的Exchanger(交換器)類。本文沒有介紹這些類的詳細的分析和使用信息,因為理解它們需要一些理論背景。

擁有了這些新的類之后,你可以說服害怕多線程技術的技術上司開發多線程應用程序了。上一頁?[1]?[2]

總結

以上是生活随笔為你收集整理的java j2se1.5_Java教程 用J2SE1.5建立多任务的Java应用程序的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。