java多線程實(shí)現(xiàn)四中方式

Java多線程實(shí)現(xiàn)的方式有四種
1.繼承Thread類,重寫run方法
2.實(shí)現(xiàn)Runnable接口,重寫run方法,實(shí)現(xiàn)Runnable接口的實(shí)現(xiàn)類的實(shí)例對象作為Thread構(gòu)造函數(shù)的target
3.通過Callable和FutureTask創(chuàng)建線程
4.通過線程池創(chuàng)建線程

前面兩種可以歸結(jié)為一類:無返回值,原因很簡單,通過重寫run方法,run方式的返回值是void,所以沒有辦法返回結(jié)果
后面兩種可以歸結(jié)成一類:有返回值,通過Callable接口,就要實(shí)現(xiàn)call方法,這個方法的返回值是Object,所以返回的結(jié)果可以放在Object對象中

方式1:繼承Thread類的線程實(shí)現(xiàn)方式如下:

public class ThreadDemo01 extends Thread{
public ThreadDemo01(){
//編寫子類的構(gòu)造方法,可缺省
}
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());
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
程序結(jié)果:
Thread[main,5,main]
我是自定義的線程1

線程實(shí)現(xiàn)方式2:通過實(shí)現(xiàn)Runnable接口,實(shí)現(xiàn)run方法,接口的實(shí)現(xiàn)類的實(shí)例作為Thread的target作為參數(shù)傳入帶參的Thread構(gòu)造函數(shù),通過調(diào)用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()+"-->我是通過實(shí)現(xiàn)接口的線程實(shí)現(xiàn)方式!");
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
程序運(yùn)行結(jié)果:
main
Thread-0–>我是通過實(shí)現(xiàn)接口的線程實(shí)現(xiàn)方式!

線程實(shí)現(xiàn)方式3:通過Callable和FutureTask創(chuàng)建線程
a:創(chuàng)建Callable接口的實(shí)現(xiàn)類 ,并實(shí)現(xiàn)Call方法
b:創(chuàng)建Callable實(shí)現(xiàn)類的實(shí)現(xiàn),使用FutureTask類包裝Callable對象,該FutureTask對象封裝了Callable對象的Call方法的返回值
c:使用FutureTask對象作為Thread對象的target創(chuàng)建并啟動線程
d:調(diào)用FutureTask對象的get()來獲取子線程執(zhí)行結(jié)束的返回值

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()+"-->我是通過實(shí)現(xiàn)Callable接口通過FutureTask包裝器來實(shí)現(xiàn)的線程");
    return null;
}   

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
程序運(yùn)行結(jié)果:
main
Thread-0–>我是通過實(shí)現(xiàn)Callable接口通過FutureTask包裝器來實(shí)現(xiàn)的線程

線程實(shí)現(xiàn)方式4:通過線程池創(chuàng)建線程

public class ThreadDemo05{

private static int POOL_NUM = 10;     //線程池數(shù)量

/**
 * @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);  
    }
    //關(guān)閉線程池
    executorService.shutdown(); 
}   

}

class RunnableThread implements Runnable
{
@Override
public void run()
{
System.out.println("通過線程池方式創(chuàng)建的線程:" + Thread.currentThread().getName() + " ");

}  

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
程序運(yùn)行結(jié)果:
通過線程池方式創(chuàng)建的線程:pool-1-thread-3
通過線程池方式創(chuàng)建的線程:pool-1-thread-4
通過線程池方式創(chuàng)建的線程:pool-1-thread-1
通過線程池方式創(chuàng)建的線程:pool-1-thread-5
通過線程池方式創(chuàng)建的線程:pool-1-thread-2
通過線程池方式創(chuàng)建的線程:pool-1-thread-5
通過線程池方式創(chuàng)建的線程:pool-1-thread-1
通過線程池方式創(chuàng)建的線程:pool-1-thread-4
通過線程池方式創(chuàng)建的線程:pool-1-thread-3
通過線程池方式創(chuàng)建的線程:pool-1-thread-2

ExecutorService、Callable都是屬于Executor框架。返回結(jié)果的線程是在JDK1.5中引入的新特征,還有Future接口也是屬于這個框架,有了這種特征得到返回值就很方便了。
通過分析可以知道,他同樣也是實(shí)現(xiàn)了Callable接口,實(shí)現(xiàn)了Call方法,所以有返回值。這也就是正好符合了前面所說的兩種分類

執(zhí)行Callable任務(wù)后,可以獲取一個Future的對象,在該對象上調(diào)用get就可以獲取到Callable任務(wù)返回的Object了。get方法是阻塞的,即:線程無返回結(jié)果,get方法會一直等待。

再介紹Executors類:提供了一系列工廠方法用于創(chuàng)建線程池,返回的線程池都實(shí)現(xiàn)了ExecutorService接口。

public static ExecutorService newFixedThreadPool(int nThreads)
創(chuàng)建固定數(shù)目線程的線程池。
public static ExecutorService newCachedThreadPool()
創(chuàng)建一個可緩存的線程池,調(diào)用execute 將重用以前構(gòu)造的線程(如果線程可用)。如果現(xiàn)有線程沒有可用的,則創(chuàng)建一個新線程并添加到池中。終止并從緩存中移除那些已有 60 秒鐘未被使用的線程。
public static ExecutorService newSingleThreadExecutor()
創(chuàng)建一個單線程化的Executor。
public static ScheduledExecutorService newScheduledThreadPool(int
corePoolSize)
創(chuàng)建一個支持定時及周期性的任務(wù)執(zhí)行的線程池,多數(shù)情況下可用來替代Timer類。
ExecutoreService提供了submit()方法,傳遞一個Callable,或Runnable,返回Future。如果Executor后臺線程池還沒有完成Callable的計算,這調(diào)用返回Future對象的get()方法,會阻塞直到計算完成。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 進(jìn)程和線程 進(jìn)程 所有運(yùn)行中的任務(wù)通常對應(yīng)一個進(jìn)程,當(dāng)一個程序進(jìn)入內(nèi)存運(yùn)行時,即變成一個進(jìn)程.進(jìn)程是處于運(yùn)行過程中...
    勝浩_ae28閱讀 5,258評論 0 23
  • 先看幾個概念:線程:進(jìn)程中負(fù)責(zé)程序執(zhí)行的執(zhí)行單元。一個進(jìn)程中至少有一個線程。多線程:解決多任務(wù)同時執(zhí)行的需求,合理...
    yeying12321閱讀 614評論 0 0
  • 本文是我自己在秋招復(fù)習(xí)時的讀書筆記,整理的知識點(diǎn),也是為了防止忘記,尊重勞動成果,轉(zhuǎn)載注明出處哦!如果你也喜歡,那...
    波波波先森閱讀 11,629評論 4 56
  • lambda 表達(dá)式是 Java 8 支持的新特性之一。通過 lambda 表達(dá)式,Java 具備了函數(shù)式編程的能...
    程序之心閱讀 644評論 0 2
  • 不論你有多好多差,多貌美,多平庸,這世上只有一個你,獨(dú)一無二的你,不可復(fù)制,無法替代。 和朋友A聊起來她剛剛通過家...
    沒有故事的袁同學(xué)閱讀 665評論 1 2

友情鏈接更多精彩內(nèi)容