您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“Java怎么創(chuàng)建線程及配合使用Lambda方式”的有關(guān)知識(shí),在實(shí)際案例的操作過程中,不少人都會(huì)遇到這樣的困境,接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
一、創(chuàng)建線程三種方式
1.1 繼承Thread類創(chuàng)建線程類
1.2 通過Runnable接口創(chuàng)建線程類
使用Lambda表達(dá)式
1.3 通過Callable和Future創(chuàng)建線程
使用Lambda表達(dá)式
二、創(chuàng)建線程的三種方式的對(duì)比
2.1 實(shí)現(xiàn)Runnable、Callable接口的方式創(chuàng)建多線程
2.2 繼承Thread類的方式創(chuàng)建多線程
2.3 Runnable和Callable的區(qū)別
定義Thread類的子類,并重寫該類的run方法,該run方法的方法體就代表了線程要完成的任務(wù)。因此把run()方法稱為執(zhí)行體。
創(chuàng)建Thread子類的實(shí)例,即創(chuàng)建了線程對(duì)象。
調(diào)用線程對(duì)象的start()方法來啟動(dòng)該線程。
public class FirstThreadTest extends Thread { int i = 0; // 重寫run方法,run方法的方法體就是現(xiàn)場執(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í)行的線程對(duì)象。GetName()方法返回調(diào)用該方法的線程的名字。
定義runnable接口的實(shí)現(xiàn)類,并重寫該接口的run()方法,該run()方法的方法體同樣是該線程的線程執(zhí)行體。
創(chuàng)建 Runnable實(shí)現(xiàn)類的實(shí)例,并以此實(shí)例作為Thread的target來創(chuàng)建Thread對(duì)象,該Thread對(duì)象才是真正的線程對(duì)象。
調(diào)用線程對(duì)象的start()方法來啟動(dòng)該線程。
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, "新線程1").start(); new Thread(rtt, "新線程2").start(); } } } }
線程的執(zhí)行流程很簡單,當(dāng)執(zhí)行代碼start()時(shí),就會(huì)執(zhí)行對(duì)象中重寫的void run();方法,該方法執(zhí)行完成后,線程就消亡了。
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, "線程1").start(); ; new Thread(RunnableThreadTest::threadRunCode_Static, "線程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, "線程1").start(); new Thread(temp::threadRunCode, "線程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); } },"線程1").start(); new Thread(() -> { for (int b = 0; b < 5; b++) { System.out.println(Thread.currentThread().getName() + " " + b); } },"線程2").start(); } } } }
public interface Callable{ V call() throws Exception; }
創(chuàng)建Callable接口的實(shí)現(xiàn)類,并實(shí)現(xiàn)call()方法,該call()方法將作為線程執(zhí)行體,并且有返回值。
創(chuàng)建Callable實(shí)現(xiàn)類的實(shí)例,使用FutureTask類來包裝Callable對(duì)象,該FutureTask對(duì)象封裝了該Callable對(duì)象的call()方法的返回值。(FutureTask是一個(gè)包裝器,它通過接受Callable來創(chuàng)建,它同時(shí)實(shí)現(xiàn)了Future和Runnable接口。)
使用FutureTask對(duì)象作為Thread對(duì)象的target創(chuàng)建并啟動(dòng)新線程。
調(diào)用FutureTask對(duì)象的get()方法來獲得子線程執(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, "有返回值的線程").start(); } } try { System.out.println("子線程的返回值:" + ft.get()); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } }
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, "有返回值的線程").start(); } } try { System.out.println("子線程的返回值:" + ft.get()); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } } }
優(yōu)勢:
線程類只是實(shí)現(xiàn)了Runnable接口或Callable接口,還可以繼承其他類。
在這種方式下,多個(gè)線程可以共享同一個(gè)target對(duì)象,所以非常適合多個(gè)相同線程來處理同一份資源的情況,從而可以將CPU、代碼和數(shù)據(jù)分開,形成清晰的模型,較好地體現(xiàn)了面向?qū)ο蟮乃枷搿?/p>
劣勢:
編程稍微復(fù)雜,如果要訪問當(dāng)前線程,則必須使用Thread.currentThread()方法。
優(yōu)勢:
編寫簡單,如果需要訪問當(dāng)前線程,則無需使用Thread.currentThread()方法,直接使用this即可獲得當(dāng)前線程。
劣勢:
線程類已經(jīng)繼承了Thread類,所以不能再繼承其他父類。
Callable規(guī)定(重寫)的方法是call(),Runnable規(guī)定(重寫)的方法是run()。
Callable的任務(wù)執(zhí)行后可返回值,而Runnable的任務(wù)是不能返回值的。
call方法可以拋出異常,run方法不可以。
運(yùn)行Callable任務(wù)可以拿到一個(gè)Future對(duì)象,表示異步計(jì)算的結(jié)果。它提供了檢查計(jì)算是否完成的方法,以等待計(jì)算的完成,并檢索計(jì)算的結(jié)果。通過Future對(duì)象可以了解任務(wù)執(zhí)行情況,可取消任務(wù)的執(zhí)行,還可獲取執(zhí)行結(jié)果。
“Java怎么創(chuàng)建線程及配合使用Lambda方式”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。