java 線程三種實現方式，java線程三種實現

java 線程三種實現方式，java線程三種實現

1繼承thread

public class MultiThread1 extends Thread{
public void run(){
for(int i=0; i<7; i++){
System.out.println("name:"+this.getName()+" i:"+ i+"   ");
}
}
public static void main(String[] args) {
MultiThread1 tA = new MultiThread1();
tA.setName("AA");
MultiThread1 tB = new MultiThread1();
tB.setName("BB");
tA.start();
tB.start();
}
}

2實現Runnable

public class MyRunnable implements Runnable{
private String name;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public void run() {
// TODO Auto-generated method stub
for(int i=0; i<10; i++){
System.out.println("name:"+this.getName()+" i:"+ i+"   ");
}
}
public static void main(String[] args) {
MyRunnable mA = new MyRunnable();
mA.setName("AA");
MyRunnable mB = new MyRunnable();
mB.setName("BB");
Thread t1 = new Thread(mA);
Thread t2 = new Thread(mB);
t1.start();
t2.start();
}
}

3 使用ExecutorService、Callable、Future實現有返回結果的多線程
ExecutorService、Callable、Future這個對象實際上都是屬於Executor框架中的功能類。想要詳細了解Executor框架的可以訪問http://www.javaeye.com/topic/366591 ，這裡面對該框架做了很詳細的解釋。返回結果的線程是在JDK1.5中引入的新特征，確實很實用，有了這種特征我就不需要再為了得到返回值而大費周折了，而且即便實現了也可能漏洞百出。
可返回值的任務必須實現Callable接口，類似的，無返回值的任務必須Runnable接口。執行Callable任務後，可以獲取一個Future的對象，在該對象上調用get就可以獲取到Callable任務返回的Object了，再結合線程池接口ExecutorService就可以實現傳說中有返回結果的多線程了。下面提供了一個完整的有返回結果的多線程測試例子，在JDK1.5下驗證過沒問題可以直接使用。

import java.util.concurrent.*;
import java.util.Date;
import java.util.List;
import java.util.ArrayList;
/**
* 有返回值的線程
*/
@SuppressWarnings("unchecked")
public class Test {
public static void main(String[] args) throws ExecutionException,
    InterruptedException {
   System.out.println("----程序開始運行----");
   Date date1 = new Date();
   int taskSize = 5;
   // 創建一個線程池
   ExecutorService pool = Executors.newFixedThreadPool(taskSize);
   // 創建多個有返回值的任務
   List<Future> list = new ArrayList<Future>();
   for (int i = 0; i < taskSize; i++) {
    Callable c = new MyCallable(i + " ");
    // 執行任務並獲取Future對象
    Future f = pool.submit(c);
    // System.out.println(">>>" + f.get().toString());
    list.add(f);
   }
   // 關閉線程池
   pool.shutdown();
   // 獲取所有並發任務的運行結果
   for (Future f : list) {
    // 從Future對象上獲取任務的返回值，並輸出到控制台
    System.out.println(">>>" + f.get().toString());
   }
   Date date2 = new Date();
   System.out.println("----程序結束運行----，程序運行時間【"
     + (date2.getTime() - date1.getTime()) + "毫秒】");
}
}
class MyCallable implements Callable<Object> {
private String taskNum;
MyCallable(String taskNum) {
   this.taskNum = taskNum;
}
public Object call() throws Exception {
   System.out.println(">>>" + taskNum + "任務啟動");
   Date dateTmp1 = new Date();
   Thread.sleep(1000);
   Date dateTmp2 = new Date();
   long time = dateTmp2.getTime() - dateTmp1.getTime();
   System.out.println(">>>" + taskNum + "任務終止");
   return taskNum + "任務返回運行結果,當前任務時間【" + time + "毫秒】";
}
}