淺析 Java多線程
什么是進程
當一個程序進入內(nèi)存中運行起來它就變?yōu)橐粋€進程。因此,進程就是一個處于運行狀態(tài)的程序。同時進程具有獨立功能,進程是操作系統(tǒng)進行資源分配和調(diào)度的獨立單位。
什么是線程
線程是進程的組成部分。通常情況下,一個進程可擁有多個線程,而一個線程只能擁有一個父進程。
線程可以擁有自己的堆棧、自己的程序計數(shù)器及自己的局部變量,但是線程不能擁有系統(tǒng)資源,它與其父進程的其他線程共享進程中的全部資源,這其中包括進程的代碼段、數(shù)據(jù)段、堆空間以及一些進程級的資源(例如,打開的文件等)。
線程是進程的執(zhí)行單元,是CPU調(diào)度和分派的基本單位,當進程被初始化之后,主線程就會被創(chuàng)建。同時如果有需要,還可以在程序執(zhí)行過程中創(chuàng)建出其他線程,這些線程之間也是相互獨立的,并且在同一進程中并發(fā)執(zhí)行。因此一個進程中可以包含多個線程,但是至少要包含一個線程,即主線程。
Java中的線程
Java 中使用Thread類表示一個線程。所有的線程對象都必須是Thread或其子類的對象。Thread 類中的 run 方法是該線程的執(zhí)行代碼。讓我們來看一個實例:
public class Ticket extends Thread{ // 重寫run方法 public void run() { for (int i = 0; i < 20; i++) { System.out.println(getName() + ": " + i); } } }
public class TestThread { public static void main(String[] args) { // 1.創(chuàng)建線程 Thread thread1 = new Ticket(); Thread thread2 = new Ticket(); // 2.啟動線程 thread1.start(); thread2.start(); } }
運行結(jié)果如下:
通過上面的代碼和運行結(jié)果,我們可以得到:
線程運行的幾個特點
1.同一進程下不同線程的調(diào)度不由程序控制。線程的執(zhí)行是搶占式的,運行的順序和線程的啟動順序是無關(guān)的,當前運行的線程隨時都可能被掛起,然后其他進程搶占運行。
2.線程獨享自己的堆棧程序計數(shù)器和局部變量。兩個進程的局部變量互不干擾,各自的執(zhí)行順序也是互不干擾。
3.兩個線程并發(fā)執(zhí)行。兩個線程同時向前推進,并沒有說執(zhí)行完一個后再執(zhí)行另一個。
start()方法和run()方法
啟動一個線程必須調(diào)用Thread 類的 start()方法,使該線程處于就緒狀態(tài),這樣該線程就可以被處理器調(diào)度。
run()方法是一個線程所關(guān)聯(lián)的執(zhí)行代碼,無論是派生自 Thread類的線程類,還是實現(xiàn)Runnable接口的類,都必須實現(xiàn)run()方法,run()方法里是我們需要線程所執(zhí)行的代碼。
實現(xiàn)多線程必須調(diào)用Thread 類的 start()方法來啟動線程,使線程處于就緒狀態(tài)隨時供CPU調(diào)度。如果直接調(diào)用run()方法的話,只是調(diào)用了Thread類的一個普通方法,會立即執(zhí)行該方法中的代碼,并沒有實現(xiàn)多線程技術(shù)。
Java中多線程的實現(xiàn)方法
在Java中有三種方法實現(xiàn)多線程。
第一種方法:使用Thread類或者使用一個派生自Thread 類的類構(gòu)建一個線程。
第二種方法:實現(xiàn)Runnable 接口來構(gòu)建一個線程。(推薦使用)
第三種方法:實現(xiàn)Callable 接口來構(gòu)建一個線程。(有返回值)
第一種方法
使用Thread類或者使用一個派生自Thread 類的類構(gòu)建一個線程。
public class Ticket extends Thread{ // 重寫run方法 public void run() { for (int i = 0; i < 20; i++) { System.out.println(getName() + ": " + i); } } }
public class TestThread { public static void main(String[] args) { // 1.創(chuàng)建線程 Thread thread1 = new Ticket(); Thread thread2 = new Ticket(); // 2.啟動線程 thread1.start(); thread2.start(); } }
看上面的代碼,我們創(chuàng)建了一個Ticket類,它繼承了Thread類,重寫了Thread類的run方法。然后我們用Ticket類創(chuàng)建了兩個線程,并且啟動了它們。但我們不推薦使用這種方法,因為一個類繼承了Thread類,那它就沒有辦法繼承其他類了,這對較為復雜的程序開發(fā)是不利的。
第二種方法
實現(xiàn)Runnable 接口來構(gòu)建一個線程。
public class Ticket implements Runnable{ // 重寫run方法 public void run() { for (int i = 0; i < 20; i++) { System.out.println(Thread.currentThread().getName() + ": " + i); } } }
public class TestThread { public static void main(String[] args) { // 1.創(chuàng)建線程 Ticket t1 = new Ticket(); Ticket t2 = new Ticket(); Thread thread1 = new Thread(t1, "買票1號"); Thread thread2 = new Thread(t2, "買票2號"); // 2.啟動線程 thread1.start(); thread2.start(); } }
我們創(chuàng)建了一個Ticket類,實現(xiàn)了Runnable接口,在該類中實現(xiàn)了run方法。在啟動線程前,我們要創(chuàng)建一個線程對象,不同的是我們要將一個實現(xiàn)了Runnable接口的類的對象作為Thread類構(gòu)造方法的參數(shù)傳入,以構(gòu)建線程對象。構(gòu)造方法Thread的第二個參數(shù)用來指定該線程的名字,通過Thread.currentThread().getName()可獲取當前線程的名字。
在真實的項目開發(fā)中,推薦使用實現(xiàn)Runnable接口的方法進行多線程編程。因為這樣既可以實現(xiàn)一個線程的功能,又可以更好地復用其他類的屬性和方法。
第三種方法
實現(xiàn)Callable 接口來構(gòu)建一個線程。
public class TestThread { public static void main(String[] args) { // 1.創(chuàng)建Callable的實例 Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(7000); return "我結(jié)束了"; } }; // 2.通過FutureTask接口的實例包裝Callable的實例 FutureTask<String> futureTask = new FutureTask<String>(callable); // 3.創(chuàng)建線程并啟動 new Thread(futureTask).start(); // 4.獲得結(jié)果并打印 try { System.out.println(futureTask.get()); } catch (Exception e) { e.printStackTrace(); } } }
首先我們用匿名內(nèi)部類創(chuàng)建了一個實現(xiàn)Callable接口的類的對象,然后通過FutureTask 的實例包裝了Callable的實例,這樣我們就可以通過一個Thread 對象在新線程中執(zhí)行call()方法,同時又可以通過get方法獲取到call()的返回值。然后創(chuàng)建線程并啟動它,最后在線程執(zhí)行完執(zhí)行完call()方法后得到返回值并打印。
我們來看一下Callable的源碼:
public interface Callable<V> { /** * Computes a result, or throws an exception if unable to do so. * * @return computed result * @throws Exception if unable to compute a result */ V call() throws Exception; }
從Callable 的定義可以看出,Callable接口是一個泛型接口,它定義的call()方法類似于Runnable 的run()方法,是線程所關(guān)聯(lián)的執(zhí)行代碼。但是與run()方法不同的是,call()方法具有返回值,并且泛型接口的參數(shù)V指定了call()方法的返回值類型。同時,如果call()方法得不到返回值將會拋出一個異常,而在Runnable的run()方法中不能拋出異常。
如何獲得call()方法的返回值
通過Future接口來獲取。Future接口定義了一組對 Runnable 或者Callable 任務的執(zhí)行結(jié)果進行取消、查詢、獲取、設(shè)置的操作。其中g(shù)et方法用于獲取call()的返回值,它會發(fā)生阻塞,直到call()返回結(jié)果。
這樣的線程調(diào)用與直接同步調(diào)用函數(shù)有什么差異
在上面的例子中,通過future.get()獲取 call()的返回值時,由于call方法中會 sleep 7s,所以在執(zhí)行future.get()的時候主線程會被阻塞而什么都不做,等待call()執(zhí)行完并得到返回值。但是這與直接調(diào)用函數(shù)獲取返回值還是有本質(zhì)區(qū)別的。
因為call()方法是運行在其他線程里的,在這個過程中主線程并沒有被阻塞,還是可以做其他事情的,除非執(zhí)行future.get()去獲取 call()的返回值時主線程才會被阻塞。所以當調(diào)用了Thread.start()方法啟動 Callable 線程后主線程可以執(zhí)行別的工作,當需要call()的返回值時再去調(diào)用future.get()獲取,此時call()方法可能早已執(zhí)行完畢,這樣就可以既確保耗時操作在工作線程中完成而不阻擋主線程,又可以得到線程執(zhí)行結(jié)果的返回值。而直接調(diào)用函數(shù)獲取返回值是一個同步操作,該函數(shù)本身就是運行在主線程中,所以一旦函數(shù)中有耗時操作,必然會阻擋主線程。
以上就是淺析 Java多線程的詳細內(nèi)容,更多關(guān)于Java多線程的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
SpringBoot項目實現(xiàn)jar包方式打包部署
SpringBoot默認的打包方式就是jar包,本文就來介紹一下SpringBoot項目實現(xiàn)jar包方式打包部署,具有一定的參考價值,感興趣的可以了解一下2024-08-08java 運行報錯has been compiled by a more recent version of the J
java 運行報錯has been compiled by a more recent version of the Java Runtime (class file version 54.0)2021-04-04