快捷導(dǎo)航

Java創(chuàng)建線(xiàn)程及配合使用Lambda方式

更新時(shí)間：2021年08月24日 11:59:18 作者：FXBStudy

這篇文章主要介紹了Java創(chuàng)建線(xiàn)程及配合使用Lambda方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

一、創(chuàng)建線(xiàn)程三種方式

1.1 繼承Thread類(lèi)創(chuàng)建線(xiàn)程類(lèi)

定義Thread類(lèi)的子類(lèi)，并重寫(xiě)該類(lèi)的run方法，該run方法的方法體就代表了線(xiàn)程要完成的任務(wù)。因此把run()方法稱(chēng)為執(zhí)行體。
創(chuàng)建Thread子類(lèi)的實(shí)例，即創(chuàng)建了線(xiàn)程對(duì)象。
調(diào)用線(xiàn)程對(duì)象的start()方法來(lái)啟動(dòng)該線(xiàn)程。

public class FirstThreadTest extends Thread {
    int i = 0;
    // 重寫(xiě)run方法，run方法的方法體就是現(xiàn)場(chǎng)執(zhí)行體
    public void run() {
        for (; i < 5; i++) {
            System.out.println(getName() + "  " + i);
        }
    }
    public static void main(String[] args) {
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + "  : " + i);
            if (i == 2) {
                new FirstThreadTest().start();
                new FirstThreadTest().start();
            }
        }
    }
}

上述代碼中Thread.currentThread()方法返回當(dāng)前正在執(zhí)行的線(xiàn)程對(duì)象。GetName()方法返回調(diào)用該方法的線(xiàn)程的名字。

1.2 通過(guò)Runnable接口創(chuàng)建線(xiàn)程類(lèi)

定義runnable接口的實(shí)現(xiàn)類(lèi)，并重寫(xiě)該接口的run()方法，該run()方法的方法體同樣是該線(xiàn)程的線(xiàn)程執(zhí)行體。
創(chuàng)建 Runnable實(shí)現(xiàn)類(lèi)的實(shí)例，并以此實(shí)例作為T(mén)hread的target來(lái)創(chuàng)建Thread對(duì)象，該Thread對(duì)象才是真正的線(xiàn)程對(duì)象。
調(diào)用線(xiàn)程對(duì)象的start()方法來(lái)啟動(dòng)該線(xiàn)程。

public class RunnableThreadTest implements Runnable {
    private int i;
    public void run() {
        for (i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
        }
    }
    public static void main(String[] args) {
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i == 2) {
                RunnableThreadTest rtt = new RunnableThreadTest();
                new Thread(rtt, "新線(xiàn)程1").start();
                new Thread(rtt, "新線(xiàn)程2").start();
            }
        }
    }
}

線(xiàn)程的執(zhí)行流程很簡(jiǎn)單，當(dāng)執(zhí)行代碼start()時(shí)，就會(huì)執(zhí)行對(duì)象中重寫(xiě)的void run();方法，該方法執(zhí)行完成后，線(xiàn)程就消亡了。

使用Lambda表達(dá)式

public class RunnableThreadTest {
    // 目的是為了代碼的重用【靜態(tài)方法】
    public static void threadRunCode_Static() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
        }
    }
    // 目的是為了代碼的重用【非靜態(tài)方法】
    public void threadRunCode() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
        }
    }
    @Test
    public void testStatic() {
        // 重用靜態(tài)方法中的代碼【使用方法引用】
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i == 2) {
                new Thread(RunnableThreadTest::threadRunCode_Static, "線(xiàn)程1").start();
                ;
                new Thread(RunnableThreadTest::threadRunCode_Static, "線(xiàn)程2").start();
                ;
            }
        }
    }
    @Test
    public void testNoStatic() {
        // 重用非靜態(tài)方法中的代碼【使用方法引用】
        RunnableThreadTest temp = new RunnableThreadTest();
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i == 2) {
                new Thread(temp::threadRunCode, "線(xiàn)程1").start();
                new Thread(temp::threadRunCode, "線(xiàn)程2").start();
            }
        }
    }
    @Test
    public void testLambda() {
        // 重用靜態(tài)方法中的代碼【使用方法引用】
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i == 2) {
                new Thread(() -> {
                    for (int b = 0; b < 5; b++) {
                        System.out.println(Thread.currentThread().getName() + " " + b);
                    }
                },"線(xiàn)程1").start();
                new Thread(() -> {
                    for (int b = 0; b < 5; b++) {
                        System.out.println(Thread.currentThread().getName() + " " + b);
                    }
                },"線(xiàn)程2").start();
            }
        }
    }
}

1.3 通過(guò)Callable和Future創(chuàng)建線(xiàn)程

public interface Callable{
　　V call() throws Exception;
}

創(chuàng)建Callable接口的實(shí)現(xiàn)類(lèi)，并實(shí)現(xiàn)call()方法，該call()方法將作為線(xiàn)程執(zhí)行體，并且有返回值。
創(chuàng)建Callable實(shí)現(xiàn)類(lèi)的實(shí)例，使用FutureTask類(lèi)來(lái)包裝Callable對(duì)象，該FutureTask對(duì)象封裝了該Callable對(duì)象的call()方法的返回值。（FutureTask是一個(gè)包裝器，它通過(guò)接受Callable來(lái)創(chuàng)建，它同時(shí)實(shí)現(xiàn)了Future和Runnable接口。）
使用FutureTask對(duì)象作為T(mén)hread對(duì)象的target創(chuàng)建并啟動(dòng)新線(xiàn)程。
調(diào)用FutureTask對(duì)象的get()方法來(lái)獲得子線(xiàn)程執(zhí)行結(jié)束后的返回值

public class CallableThreadTest implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        int i = 0;
        for (; i < 5; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
        }
        return i;
    }
    public static void main(String[] args) {
        CallableThreadTest ctt = new CallableThreadTest();
        FutureTask<Integer> ft = new FutureTask<>(ctt);
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " 的循環(huán)變量i的值" + i);
            if (i == 2) {
                new Thread(ft, "有返回值的線(xiàn)程").start();
            }
        }
        try {
            System.out.println("子線(xiàn)程的返回值：" + ft.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
}

使用Lambda表達(dá)式

public class CallableThreadTest {
    public static void main(String[] args) {
        FutureTask<Integer> ft = new FutureTask<>(() -> {
            int i = 0;
            for (; i < 5; i++) {
                System.out.println(Thread.currentThread().getName() + " " + i);
            }
            return i;
        });
        for (int i = 0; i < 3; i++) {
            System.out.println(Thread.currentThread().getName() + " 的循環(huán)變量i的值" + i);
            if (i == 2) {
                new Thread(ft, "有返回值的線(xiàn)程").start();
            }
        }
        try {
            System.out.println("子線(xiàn)程的返回值：" + ft.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
}

二、創(chuàng)建線(xiàn)程的三種方式的對(duì)比

2.1 實(shí)現(xiàn)Runnable、Callable接口的方式創(chuàng)建多線(xiàn)程

優(yōu)勢(shì)：

線(xiàn)程類(lèi)只是實(shí)現(xiàn)了Runnable接口或Callable接口，還可以繼承其他類(lèi)。
在這種方式下，多個(gè)線(xiàn)程可以共享同一個(gè)target對(duì)象，所以非常適合多個(gè)相同線(xiàn)程來(lái)處理同一份資源的情況，從而可以將CPU、代碼和數(shù)據(jù)分開(kāi)，形成清晰的模型，較好地體現(xiàn)了面向?qū)ο蟮乃枷搿?/li>

劣勢(shì)：

編程稍微復(fù)雜，如果要訪問(wèn)當(dāng)前線(xiàn)程，則必須使用Thread.currentThread()方法。

2.2 繼承Thread類(lèi)的方式創(chuàng)建多線(xiàn)程

優(yōu)勢(shì)：

編寫(xiě)簡(jiǎn)單，如果需要訪問(wèn)當(dāng)前線(xiàn)程，則無(wú)需使用Thread.currentThread()方法，直接使用this即可獲得當(dāng)前線(xiàn)程。

劣勢(shì)：

線(xiàn)程類(lèi)已經(jīng)繼承了Thread類(lèi)，所以不能再繼承其他父類(lèi)。

2.3 Runnable和Callable的區(qū)別

Callable規(guī)定（重寫(xiě)）的方法是call()，Runnable規(guī)定（重寫(xiě)）的方法是run()。
Callable的任務(wù)執(zhí)行后可返回值，而Runnable的任務(wù)是不能返回值的。
call方法可以?huà)伋霎惓＃瑀un方法不可以。
運(yùn)行Callable任務(wù)可以拿到一個(gè)Future對(duì)象，表示異步計(jì)算的結(jié)果。它提供了檢查計(jì)算是否完成的方法，以等待計(jì)算的完成，并檢索計(jì)算的結(jié)果。通過(guò)Future對(duì)象可以了解任務(wù)執(zhí)行情況，可取消任務(wù)的執(zhí)行，還可獲取執(zhí)行結(jié)果。

拓展：

Lambda表達(dá)式的強(qiáng)大之處就是傳遞代碼，而Runnable和Callable接口都是符合Lambda要求的函數(shù)式接口。因此，我們可以不用創(chuàng)建這兩個(gè)接口的實(shí)現(xiàn)類(lèi)，而是直接將其中的實(shí)現(xiàn)代碼傳遞到Thread的target即可。

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: