1. 程式人生 > >Java多執行緒實現的方式

Java多執行緒實現的方式

Java多執行緒實現的方式有四種

1.繼承Thread類,重寫run方法
2.實現Runnable介面,重寫run方法,實現Runnable介面的實現類的例項物件作為Thread建構函式的target
3.通過Callable和FutureTask建立執行緒
4.通過執行緒池建立執行緒

前面兩種可以歸結為一類:無返回值,原因很簡單,通過重寫run方法,run方式的返回值是void,所以沒有辦法返回結果
後面兩種可以歸結成一類:有返回值,通過Callable介面,就要實現call方法,這個方法的返回值是Object,所以返回的結果可以放在Object物件中

方式1:繼承Thread類的執行緒實現方式如下:

public class ThreadDemo01 extends Thread{
    public ThreadDemo01(){
        //編寫子類的構造方法,可預設
    }
    public void run(){
        //編寫自己的執行緒程式碼
        System.out.println(Thread.currentThread().getName());
    }
    public static void main(String[] args){ 
        ThreadDemo01 threadDemo01 = new ThreadDemo01(); 
        threadDemo01.setName("我是自定義的執行緒1");
        threadDemo01.start();       
        System.out.println(Thread.currentThread().toString());  
    }
}

程式結果:
Thread[main,5,main]
我是自定義的執行緒1

執行緒實現方式2:通過實現Runnable介面,實現run方法,介面的實現類的例項作為Thread的target作為引數傳入帶參的Thread建構函式,通過呼叫start()方法啟動執行緒

public class ThreadDemo02 {

    public static void main(String[] args){ 
        System.out.println(Thread.currentThread().getName());
        Thread t1 = new Thread(new MyThread());
        t1.start(); 
    }
}

class MyThread implements Runnable{
    @Override
    public void run() {
        // TODO Auto-generated method stub
        System.out.println(Thread.currentThread().getName()+"-->我是通過實現介面的執行緒實現方式!");
    }   
}

程式執行結果:
main
Thread-0–>我是通過實現介面的執行緒實現方式!

執行緒實現方式3:通過Callable和FutureTask建立執行緒
a:建立Callable介面的實現類 ,並實現Call方法
b:建立Callable實現類的實現,使用FutureTask類包裝Callable物件,該FutureTask物件封裝了Callable物件的Call方法的返回值
c:使用FutureTask物件作為Thread物件的target建立並啟動執行緒
d:呼叫FutureTask物件的get()來獲取子執行緒執行結束的返回值

public class ThreadDemo03 {

    /**
     * @param args
     */
    public static void main(String[] args) {
        // TODO Auto-generated method stub

        Callable<Object> oneCallable = new Tickets<Object>();
        FutureTask<Object> oneTask = new FutureTask<Object>(oneCallable);

        Thread t = new Thread(oneTask);

        System.out.println(Thread.currentThread().getName());

        t.start();

    }

}

class Tickets<Object> implements Callable<Object>{

    //重寫call方法
    @Override
    public Object call() throws Exception {
        // TODO Auto-generated method stub
        System.out.println(Thread.currentThread().getName()+"-->我是通過實現Callable介面通過FutureTask包裝器來實現的執行緒");
        return null;
    }   
}

程式執行結果:
main
Thread-0–>我是通過實現Callable介面通過FutureTask包裝器來實現的執行緒

執行緒實現方式4:通過執行緒池建立執行緒

public class ThreadDemo05{

    private static int POOL_NUM = 10;     //執行緒池數量

    /**
     * @param args
     * @throws InterruptedException 
     */
    public static void main(String[] args) throws InterruptedException {
        // TODO Auto-generated method stub
        ExecutorService executorService = Executors.newFixedThreadPool(5);  
        for(int i = 0; i<POOL_NUM; i++)  
        {  
            RunnableThread thread = new RunnableThread();

            //Thread.sleep(1000);
            executorService.execute(thread);  
        }
        //關閉執行緒池
        executorService.shutdown(); 
    }   

}

class RunnableThread implements Runnable  
{     
    @Override
    public void run()  
    {  
        System.out.println("通過執行緒池方式建立的執行緒:" + Thread.currentThread().getName() + " ");  

    }  
}  

程式執行結果:
通過執行緒池方式建立的執行緒:pool-1-thread-3
通過執行緒池方式建立的執行緒:pool-1-thread-4
通過執行緒池方式建立的執行緒:pool-1-thread-1
通過執行緒池方式建立的執行緒:pool-1-thread-5
通過執行緒池方式建立的執行緒:pool-1-thread-2
通過執行緒池方式建立的執行緒:pool-1-thread-5
通過執行緒池方式建立的執行緒:pool-1-thread-1
通過執行緒池方式建立的執行緒:pool-1-thread-4
通過執行緒池方式建立的執行緒:pool-1-thread-3
通過執行緒池方式建立的執行緒:pool-1-thread-2

ExecutorService、Callable都是屬於Executor框架。返回結果的執行緒是在JDK1.5中引入的新特徵,還有Future介面也是屬於這個框架,有了這種特徵得到返回值就很方便了。
通過分析可以知道,他同樣也是實現了Callable介面,實現了Call方法,所以有返回值。這也就是正好符合了前面所說的兩種分類

執行Callable任務後,可以獲取一個Future的物件,在該物件上呼叫get就可以獲取到Callable任務返回的Object了。get方法是阻塞的,即:執行緒無返回結果,get方法會一直等待。

再介紹Executors類:提供了一系列工廠方法用於建立執行緒池,返回的執行緒池都實現了ExecutorService介面。

public static ExecutorService newFixedThreadPool(int nThreads)
建立固定數目執行緒的執行緒池。
public static ExecutorService newCachedThreadPool()
建立一個可快取的執行緒池,呼叫execute 將重用以前構造的執行緒(如果執行緒可用)。如果現有執行緒沒有可用的,則建立一個新執行緒並新增到池中。終止並從快取中移除那些已有 60 秒鐘未被使用的執行緒。
public static ExecutorService newSingleThreadExecutor()
建立一個單執行緒化的Executor。
public static ScheduledExecutorService newScheduledThreadPool(int
corePoolSize)
建立一個支援定時及週期性的任務執行的執行緒池,多數情況下可用來替代Timer類。
ExecutoreService提供了submit()方法,傳遞一個Callable,或Runnable,返回Future。如果Executor後臺執行緒池還沒有完成Callable的計算,這呼叫返回Future物件的get()方法,會阻塞直到計算完成。