Java創(chuàng)建線程及配合使用Lambda方式
更新時間：2021年08月24日 11:59:18 作者：FXBStudy
這篇文章主要介紹了Java創(chuàng)建線程及配合使用Lambda方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
一、創(chuàng)建線程三種方式
1.1 繼承Thread類創(chuàng)建線程類
- 定義Thread類的子類，并重寫該類的run方法，該run方法的方法體就代表了線程要完成的任務。因此把run()方法稱為執(zhí)行體。
- 創(chuàng)建Thread子類的實例，即創(chuàng)建了線程對象。
- 調(diào)用線程對象的start()方法來啟動該線程。
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()方法返回當前正在執(zhí)行的線程對象。GetName()方法返回調(diào)用該方法的線程的名字。
1.2 通過Runnable接口創(chuàng)建線程類
- 定義runnable接口的實現(xiàn)類，并重寫該接口的run()方法，該run()方法的方法體同樣是該線程的線程執(zhí)行體。
- 創(chuàng)建 Runnable實現(xiàn)類的實例，并以此實例作為Thread的target來創(chuàng)建Thread對象，該Thread對象才是真正的線程對象。
- 調(diào)用線程對象的start()方法來啟動該線程。
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í)行流程很簡單，當執(zhí)行代碼start()時，就會執(zhí)行對象中重寫的void run();方法，該方法執(zhí)行完成后，線程就消亡了。
使用Lambda表達式
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();
}
}
}
}
1.3 通過Callable和Future創(chuàng)建線程
public interface Callable{
V call() throws Exception;
}
- 創(chuàng)建Callable接口的實現(xiàn)類，并實現(xiàn)call()方法，該call()方法將作為線程執(zhí)行體，并且有返回值。
- 創(chuàng)建Callable實現(xiàn)類的實例，使用FutureTask類來包裝Callable對象，該FutureTask對象封裝了該Callable對象的call()方法的返回值。（FutureTask是一個包裝器，它通過接受Callable來創(chuàng)建，它同時實現(xiàn)了Future和Runnable接口。）
- 使用FutureTask對象作為Thread對象的target創(chuàng)建并啟動新線程。
- 調(diào)用FutureTask對象的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();
}
}
}
使用Lambda表達式
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();
}
}
}
二、創(chuàng)建線程的三種方式的對比
2.1 實現(xiàn)Runnable、Callable接口的方式創(chuàng)建多線程
優(yōu)勢：
- 線程類只是實現(xiàn)了Runnable接口或Callable接口，還可以繼承其他類。
- 在這種方式下，多個線程可以共享同一個target對象，所以非常適合多個相同線程來處理同一份資源的情況，從而可以將CPU、代碼和數(shù)據(jù)分開，形成清晰的模型，較好地體現(xiàn)了面向?qū)ο蟮乃枷搿?/li>
劣勢：
- 編程稍微復雜，如果要訪問當前線程，則必須使用Thread.currentThread()方法。
2.2 繼承Thread類的方式創(chuàng)建多線程
優(yōu)勢：
- 編寫簡單，如果需要訪問當前線程，則無需使用Thread.currentThread()方法，直接使用this即可獲得當前線程。
劣勢：
- 線程類已經(jīng)繼承了Thread類，所以不能再繼承其他父類。
2.3 Runnable和Callable的區(qū)別
- Callable規(guī)定（重寫）的方法是call()，Runnable規(guī)定（重寫）的方法是run()。
- Callable的任務執(zhí)行后可返回值，而Runnable的任務是不能返回值的。
- call方法可以拋出異常，run方法不可以。
- 運行Callable任務可以拿到一個Future對象，表示異步計算的結(jié)果。它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結(jié)果。通過Future對象可以了解任務執(zhí)行情況，可取消任務的執(zhí)行，還可獲取執(zhí)行結(jié)果。
拓展：
Lambda表達式的強大之處就是傳遞代碼，而Runnable和Callable接口都是符合Lambda要求的函數(shù)式接口。因此，我們可以不用創(chuàng)建這兩個接口的實現(xiàn)類，而是直接將其中的實現(xiàn)代碼傳遞到Thread的target即可。
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- java線程池的四種創(chuàng)建方式詳細分析
- JavaEE的進程,線程和創(chuàng)建線程的5種方式詳解
- Java的線程與進程以及線程的四種創(chuàng)建方式
- 聊聊java多線程創(chuàng)建方式及線程安全問題
- Java線程的三種創(chuàng)建方式
- Java線程創(chuàng)建的四種方式總結(jié)
- 如何在Java中創(chuàng)建線程通信的四種方式你知道嗎
- java實現(xiàn)/創(chuàng)建線程的幾種方式小結(jié)
- 很多人竟然不知道Java線程池的創(chuàng)建方式有7種
- java 創(chuàng)建線程的四種方式
- Java創(chuàng)建線程的方式解析
相關文章
這篇文章主要介紹了Spring+Quartz配置定時任務實現(xiàn)代碼,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-04-04
這篇文章主要介紹了Java進程內(nèi)緩存框架EhCache，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2021-12-12
這篇文章主要介紹了Spring框架中的@Conditional系列注解詳解,我們需要一個類實現(xiàn)Spring提供的Condition接口,它會匹配@Conditional所符合的方法,然后我們可以使用我們在@Conditional注解中定義的類來檢查,需要的朋友可以參考下2024-01-01
通過對這些屬性的配置，可以改變Struts 2 框架的一些默認行為，這些配置可以在struts.xml文件中完成，也可以在struts.properties文件中完成2016-09-09
Jasypt?(Java?Simplified?Encryption)?是一個?java?庫，它允許開發(fā)人員以最小的成本將基本的加密功能添加到項目中，而無需深入了解密碼學的工作原理。本文將利用jasypt實現(xiàn)配置文件加密，感興趣的可以學習一下2022-07-07
給大家整理了現(xiàn)在很熱門的java程序員面試時候的筆試試題以及答案，希望能幫助到你。2017-11-11
本文主要介紹了Java中Boolean引發(fā)缺陷的解決，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-06-06
Java實現(xiàn)excel動態(tài)列導出的示例代碼
這篇文章主要為大家詳細介紹了如何使用Java實現(xiàn)excel動態(tài)列導出,文中的示例代碼講解詳細,具有一定的借鑒價值,感興趣的小伙伴可以跟隨小編一起學習一下2024-03-03
后端返回各種圖片形式在前端的轉(zhuǎn)換及展示方法對比
這篇文章主要給大家介紹了關于后端返回各種圖片形式在前端的轉(zhuǎn)換及展示方法對比的相關資料,文中通過圖文介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2023-06-06
本文主要介紹了mybatis?plus常用注解的具體使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-04-04