1：三個(gè)新加的多線程包
Java 5.0里新加入了三個(gè)多線程包：java.util.concurrent, java.util.concurrent.atomic, java.util.concurrent.locks.
java.util.concurrent包含了常用的多線程工具，是新的多線程工具的主體。
java.util.concurrent.atomic包含了不用加鎖情況下就能改變值的原子變量，比如說AtomicInteger提供了addAndGet()方法。Add和Get是兩個(gè)不同的操作，為了保證別的線程不干擾，以往的做法是先鎖定共享的變量，然后在鎖定的范圍內(nèi)進(jìn)行兩步操作。但用AtomicInteger.addAndGet()就不用擔(dān)心鎖定的事了，其內(nèi)部實(shí)現(xiàn)保證了這兩步操作是在原子量級(jí)發(fā)生的，不會(huì)被別的線程干擾。
java.util.concurrent.locks包包含鎖定的工具。
2：Callable 和 Future接口
Callable是類似于Runnable的接口，實(shí)現(xiàn)Callable接口的類和實(shí)現(xiàn)Runnable的類都是可被其它線程執(zhí)行的任務(wù)。Callable和Runnable有幾點(diǎn)不同：
Callable規(guī)定的方法是call()，而Runnable規(guī)定的方法是run().
Callable的任務(wù)執(zhí)行后可返回值，而Runnable的任務(wù)是不能返回值的。
call()方法可拋出異常，而run()方法是不能拋出異常的。
運(yùn)行Callable任務(wù)可拿到一個(gè)Future對(duì)象，通過Future對(duì)象可了解任務(wù)執(zhí)行情況，可取消任務(wù)的執(zhí)行，還可獲取任務(wù)執(zhí)行的結(jié)果。
以下是Callable的一個(gè)例子：
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類實(shí)現(xiàn)了Callable，String將是call方法的返回值類型。例子中用了String，但可以是任何Java類。
*2: call方法的返回值類型為String，這是和類的定義相對(duì)應(yīng)的。并且可以拋出異常。
*3: call方法可以拋出異常，如加重的斜體字所示。
以下是調(diào)用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: 定義了幾個(gè)任務(wù)
*2: 初始了任務(wù)執(zhí)行工具。任務(wù)的執(zhí)行框架將會(huì)在后面解釋。
*3: 執(zhí)行任務(wù)，任務(wù)啟動(dòng)時(shí)返回了一個(gè)Future對(duì)象，如果想得到任務(wù)執(zhí)行的結(jié)果或者是異�？蓪�(duì)這個(gè)Future對(duì)象進(jìn)行操作。Future所含的值必須跟Callable所含的值對(duì)映，比如說例子中Future對(duì)印Callable
*4: 任務(wù)1正常執(zhí)行完畢，future1.get()會(huì)返回線程的值
*5: 任務(wù)2在進(jìn)行一個(gè)死循環(huán)，調(diào)用future2.cancel(true)來中止此線程。傳入的參數(shù)標(biāo)明是否可打斷線程，true表明可以打斷。
*6: 任務(wù)3拋出異常，調(diào)用future3.get()時(shí)會(huì)引起異常的拋出。
運(yùn)行Executor會(huì)有以下運(yùn)行結(jié)果：
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)
…….
相關(guān)推薦：計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總| 北京 | 天津 | 上海 | 江蘇 | 山東 |
| 安徽 | 浙江 | 江西 | 福建 | 深圳 |
| 廣東 | 河北 | 湖南 | 廣西 | 河南 |
| 海南 | 湖北 | 四川 | 重慶 | 云南 |
| 貴州 | 西藏 | 新疆 | 陜西 | 山西 |
| 寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
| 黑龍江 | 內(nèi)蒙古 |
