2011年計算機等考二級JAVA學習精華整理(48)

　　1：三個新加的多線程包

　　Java 5.0里新加入了三個多線程包：java.util.concurrent, java.util.concurrent.atomic, java.util.concurrent.locks.

　　java.util.concurrent包含了常用的多線程工具，是新的多線程工具的主體。

　　java.util.concurrent.atomic包含了不用加鎖情況下就能改變值的原子變量，比如說AtomicInteger提供了addAndGet()方法。Add和Get是兩個不同的操作，為了保證別的線程不干擾，以往的做法是先鎖定共享的變量，然后在鎖定的范圍內進行兩步操作。但用AtomicInteger.addAndGet()就不用擔心鎖定的事了，其內部實現(xiàn)保證了這兩步操作是在原子量級發(fā)生的，不會被別的線程干擾。

　　java.util.concurrent.locks包包含鎖定的工具。

　　2：Callable 和 Future接口

　　Callable是類似于Runnable的接口，實現(xiàn)Callable接口的類和實現(xiàn)Runnable的類都是可被其它線程執(zhí)行的任務。Callable和Runnable有幾點不同：

　　Callable規(guī)定的方法是call()，而Runnable規(guī)定的方法是run().

　　Callable的任務執(zhí)行后可返回值，而Runnable的任務是不能返回值的。

　　call()方法可拋出異常，而run()方法是不能拋出異常的。

　　運行Callable任務可拿到一個Future對象，通過Future對象可了解任務執(zhí)行情況，可取消任務的執(zhí)行，還可獲取任務執(zhí)行的結果。

　　以下是Callable的一個例子：

　　public class DoCallStuff implements Callable{ // *1

　　private int aInt;

　　public DoCallStuff(int aInt) {

　　this.aInt = aInt;

　　}

　　public String call() throws Exception { //*2

　　boolean resultOk = false;

　　if(aInt == 0){

　　resultOk = true;

　　} else if(aInt == 1){

　　while(true){ //infinite loop

　　System.out.println("looping....");

　　Thread.sleep(3000);

　　}

　　} else {

　　throw new Exception("Callable terminated with Exception!"); //*3

　　}

　　if(resultOk){

　　return "Task done.";

　　} else {

　　return "Task failed";

　　}

　　}

　　}

　　*1: 名為DoCallStuff類實現(xiàn)了Callable，String將是call方法的返回值類型。例子中用了String，但可以是任何Java類。

　　*2: call方法的返回值類型為String，這是和類的定義相對應的。并且可以拋出異常。

　　*3: call方法可以拋出異常，如加重的斜體字所示。

　　以下是調用DoCallStuff的主程序。

　　import java.util.concurrent.ExecutionException;

　　import java.util.concurrent.ExecutorService;

　　import java.util.concurrent.Executors;

　　import java.util.concurrent.Future;

　　public class Executor {

　　public static void main(String[] args){

　　//*1

　　DoCallStuff call1 = new DoCallStuff(0);

　　DoCallStuff call2 = new DoCallStuff(1);

　　DoCallStuff call3 = new DoCallStuff(2);

　　//*2

　　ExecutorService es = Executors.newFixedThreadPool(3);

　　//*3

　　Future future1 = es.submit(call1);

　　Future future2 = es.submit(call2);

　　Future future3 = es.submit(call3);

　　try {

　　//*4

　　System.out.println(future1.get());

　　//*5

　　Thread.sleep(3000);

　　System.out.println("Thread 2 terminated? :" + future2.cancel(true));

　　//*6

　　System.out.println(future3.get());

　　} catch (ExecutionException ex) {

　　ex.printStackTrace();

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　*1: 定義了幾個任務

　　*2: 初始了任務執(zhí)行工具。任務的執(zhí)行框架將會在后面解釋。

　　*3: 執(zhí)行任務，任務啟動時返回了一個Future對象，如果想得到任務執(zhí)行的結果或者是異�？蓪�這個Future對象進行操作。Future所含的值必須跟Callable所含的值對映，比如說例子中Future對印Callable

　　*4: 任務1正常執(zhí)行完畢，future1.get()會返回線程的值

　　*5: 任務2在進行一個死循環(huán)，調用future2.cancel(true)來中止此線程。傳入的參數(shù)標明是否可打斷線程，true表明可以打斷。

　　*6: 任務3拋出異常，調用future3.get()時會引起異常的拋出。

　　運行Executor會有以下運行結果：

　　looping....

　　Task done. //*1

　　looping....

　　looping....//*2

　　looping....

　　looping....

　　looping....

　　looping....

　　Thread 2 terminated? :true //*3

　　//*4

　　java.util.concurrent.ExecutionException: java.lang.Exception: Callable terminated with Exception!

　　at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:205)

　　at java.util.concurrent.FutureTask.get(FutureTask.java:80)

　　at concurrent.Executor.main(Executor.java:43)

　　…….

　　　　　　　2010年9月計算機等級考試成績查詢時間匯總

 　　　　　　 2011計算機等級考試二級JAVA學習精華匯總