您好,登錄后才能下訂單哦!
java中有多少種方式可以實現多線程?可能很多人對此沒有深入了解過,故而小編總結了這篇文章,通過這文章的講解,希望你能夠收獲更多知識。
Java多線程的使用有三種方法:繼承Thread類、實現Runnable接口和使用Callable和Future創建線程。
一、繼承Thread類
實現方式很簡單,只需要創建一個類去繼承Thread類然后重寫run方法,在main方法中調用該類實例對象的start方法即可實現多線程并發。代碼:
public class MyThread extends Thread { @Override public void run(){ super.run(); System.out.println("執行子線程..."); } }
測試用例:
public class Test { public static void main(String[] args) { MyThread myThread = new MyThread(); myThread.start(); System.out.println("主線程..."); } }
當然,這里的結果不代表線程的執行順序,線程是并發執行的,如果多運行幾次,打印順序可能會不一樣。多線程的運行過程中,CPU是以不確定的方式去執行線程的,故運行結果與代碼的執行順序或者調用順序無關,運行結果也可能不一樣。
這里還有一個需要注意的點就是main方法中應該調用的是myThread的start方法,而不是run()方法。調用start()方法是告訴CPU此線程已經準備就緒可以執行,進而系統有時間就會來執行其run()方法。
而直接調用run()方法,則不是異步執行,而是等同于調用函數般按順序同步執行,這就失去了多線程的意義了。
二、實現Runnable接口
這種方式的實現也很簡單,就是把繼承Thread類改為實現Runnable接口。代碼如下:
public class MyRunnable implements Runnable { @Override public void run() { System.out.println("執行子線程..."); } }
測試用例:
public class Test { public static void main(String[] args) { Runnable runnable = new MyRunnable(); Thread thread = new Thread(runnable); thread.start(); System.out.println("主線程運行結束!"); } }
運行結果沒啥好說的,這里main中可以看到真正創建新線程還是通過Thread創建:
Thread thread = new Thread(runnable);
這一步Thread類的作用就是把run()方法包裝成線程執行體,然后依然通過start去告訴系統這個線程已經準備好了可以安排執行。
三、使用Callable和Future創建線程
上面的兩種方式都有這兩個問題:
1、無法獲取子線程的返回值;
2、run方法不可以拋出異常。
為了解決這兩個問題,我們就需要用到Callable這個接口了。說到接口,上面的Runnable接口實現類實例是作為Thread類的構造函數的參數傳入的,之后通過Thread的start執行run方法中的內容。但是Callable并不是Runnable的子接口,是個全新的接口,它的實例不能直接傳入給Thread構造,所以需要另一個接口來轉換一下。
Java5提供了Future接口來代表Callable接口里call()方法的返回值,并為Future接口提供了一個實現類FutureTask,該實現類的繼承關系如圖所示:
可以看到,該實現類不僅實現了Future接口,還實現了Runnable接口,所以可以直接傳給Thread構造函數。
而關于FutureTask的構造函數如下:
所以這里面其實就是要比上一個方法再多一個轉換過程,最終一樣是通過Thread的start來創建新線程。有了這個思路,代碼就很容易理解了:
import java.util.concurrent.Callable; public class MyCallable implements Callable { int i = 0; @Override public Object call() throws Exception { System.out.println(Thread.currentThread().getName()+" i的值:"+ i); return i++; //call方法可以有返回值 } }
測試:
import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class Test { public static void main(String[] args) { Callable callable = new MyCallable(); for (int i = 0; i < 10; i++) { FutureTask task = new FutureTask(callable); new Thread(task,"子線程"+ i).start(); try { //獲取子線程的返回值 System.out.println("子線程返回值:"+task.get() + "\n"); } catch (Exception e) { e.printStackTrace(); } } } }
執行結果(部分):
關于java中實現多線程的方式就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。