Java并發(fā)編程創(chuàng)建并運(yùn)行線程的方法對比

更新時(shí)間：2022年03月18日 14:48:45 作者：字母哥哥

這篇文章主要為大家詳細(xì)介紹了Java并發(fā)編程創(chuàng)建并運(yùn)行線程的方法，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助

一、創(chuàng)建并運(yùn)行線程的五種方法

第一種：繼承Thread類

這種方式是最基礎(chǔ)的一種方式，學(xué)過java的朋友都知道，不做贅述。需要注意的是：覆蓋實(shí)現(xiàn)使用的是run方法，運(yùn)行線程是start方法。

public class FirstWay extends Thread  {
    @Override
    public void run() {
        System.out.println("第一種實(shí)現(xiàn)線程的方式:繼承Thread類");
    }
    //模擬測試
    public static void main(String[] args) {
        new FirstWay().start();
    }
}

第二種：實(shí)現(xiàn)Runnable接口

第二種實(shí)現(xiàn)方式仍然很基礎(chǔ)，繼承Runnable接口，重寫run方法實(shí)現(xiàn)線程運(yùn)行邏輯。需要注意的:運(yùn)行線程需要套一層new Thread 。

public class SecondWay implements Runnable{
    @Override
    public void run() {
        System.out.println("第二種實(shí)現(xiàn)線程的方式:實(shí)現(xiàn)Runnable接口");
    }
    //模擬測試
    public static void main(String[] args) {
        new Thread(new SecondWay()).start();
    }
}

第三種：實(shí)現(xiàn)Callable接口

第三種方式是實(shí)現(xiàn)Callable接口，Callable接口與Runable接口都能實(shí)現(xiàn)線程。

public class ThirdWay implements Callable<String> {
    @Override
    public String call() throws Exception {
        System.out.println("第三種實(shí)現(xiàn)線程的方式:實(shí)現(xiàn)Callable接口");
        return "Callable接口帶返回值，可以拋出異常";
    }

    //模擬測試
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> futureTask = new FutureTask<>(new ThirdWay());
        new Thread(futureTask).start();
        //阻塞方法，獲取call方法返回值
        System.out.println(futureTask.get());  //打?。篊allable接口帶返回值，可以拋出異常
    }
}

區(qū)別如下：

Callable接口實(shí)現(xiàn)線程方法是call， Runable接口實(shí)現(xiàn)線程方法是run
Callable有返回值， Runable接口不能有返回值
Callable接口方法call返回值可以設(shè)置泛型，如下例子中使用String數(shù)據(jù)類型
Callable接口方法call方法可以拋出異常，Runable接口run方法不可以拋出異常
Callable接口方法通過new Thread(futureTask).start()運(yùn)行，F(xiàn)utureTask的get方法可以獲取Callable接口方法call方法的返回值
如果Callable接口方法call方法異常，在FutureTask的get方法調(diào)用時(shí)也會拋出同樣的異常

第四種：線程池 + execute

從JDK5版本開始，java默認(rèn)提供了線程池的支持，用線程池的方式運(yùn)行線程可以避免線程的無限擴(kuò)張導(dǎo)致應(yīng)用宕機(jī)，同時(shí)也節(jié)省了線程頻繁創(chuàng)建與銷毀的資源與時(shí)間成本。

public class FourthWay implements Runnable{
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() +
                ":實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池");
    }

    public static void main(String[] args) {
        //創(chuàng)建一個(gè)固定大小的線程池
        ExecutorService threadPool = Executors.newFixedThreadPool(5);
        for(int i = 0;i < 10;i++){
            threadPool.execute(new FourthWay());
        }
    }
}

線程池ExecutorService使用execute方法運(yùn)行Runnable接口run方法的線程實(shí)現(xiàn)，execute方法與run方法的共同特點(diǎn)是沒有返回值。

pool-1-thread-5:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-2:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-4:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-4:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-4:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-1:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-4:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-3:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-2:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池
pool-1-thread-5:實(shí)現(xiàn)線程的方式Runnable接口,但運(yùn)行方式不一樣，使用線程池

從上面的結(jié)果中可以看出，線程池中包含五個(gè)線程。線程運(yùn)行完成之后并不銷毀，而是還回到線程池，下一次執(zhí)行時(shí)從線程池中獲取線程資源再次運(yùn)行。

第五種：線程池 + submit

下面的例子線程池ExecutorService使用submit方法運(yùn)行Callable接口call方法的線程實(shí)現(xiàn)，submit方法與call方法的共同特點(diǎn)是存在返回值。

Callable接口call方法的返回值可以由泛型定義
ExecutorService線程池submit方法的返回值是Future

Future的get方法可以獲取call方法的返回值，同時(shí)如果call方法拋出異常，F(xiàn)uture的get方法也會拋出異常。

public class FifthWay implements Callable<String> {
    @Override
    public String call() throws Exception {
        return Thread.currentThread().getName() + ":Callable接口帶返回值，可以拋出異常";
    }

    //模擬測試
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        //保存多線程執(zhí)行結(jié)果
        List<String> retList = new ArrayList<>();
        //創(chuàng)建一個(gè)固定大小的線程池
        ExecutorService threadPool = Executors.newFixedThreadPool(5);
        for(int i = 0;i < 10;i++){
            Future<String> future = threadPool.submit(new FifthWay());
            retList.add(future.get());
        }
        //java8 語法，打印retlist
        retList.forEach(System.out::println);
    }
}

上文代碼中有一個(gè)小小的語法糖，retList.forEach(System.out::println);是java8提供的方法引用

pool-1-thread-1:Callable接口帶返回值，可以拋出異常
pool-1-thread-2:Callable接口帶返回值，可以拋出異常
pool-1-thread-3:Callable接口帶返回值，可以拋出異常
pool-1-thread-4:Callable接口帶返回值，可以拋出異常
pool-1-thread-5:Callable接口帶返回值，可以拋出異常
pool-1-thread-1:Callable接口帶返回值，可以拋出異常
pool-1-thread-2:Callable接口帶返回值，可以拋出異常
pool-1-thread-3:Callable接口帶返回值，可以拋出異常
pool-1-thread-4:Callable接口帶返回值，可以拋出異常
pool-1-thread-5:Callable接口帶返回值，可以拋出異常