更新時間:2019-08-26 15:22:10 來源:動力節點 瀏覽3036次
今天動力節點java學院小編分享如何新建一個線程?線程狀態是怎樣轉換的?關于線程狀態的操作是怎樣的?下面各位小伙伴就隨小編一起來看看java多線程的狀態轉換以及基本操作吧。
1、新建線程
一個java程序從main()方法開始執行,然后按照既定的代碼邏輯執行,看似沒有其他線程參與,但實際上java程序天生就是一個多線程程序,包含了:
(1)分發處理發送給給JVM信號的線程;
(2)調用對象的finalize方法的線程;
(3)清除Reference的線程;
(4)main線程,用戶程序的入口。
那么,如何在用戶程序中新建一個線程了,只要有三種方式:
A:通過繼承Thread類,重寫run方法;
B:通過實現runable接口;
C:通過實現callable接口這三種方式,下面看具體demo。
ublic class CreateThreadDemo {
public static void main(String[] args) {
//1.繼承Thread
Thread thread = new Thread() {
@Override
public void run() {
System.out.println("繼承Thread");
super.run();
}
};
thread.start();
//2.實現runable接口
Thread thread1 = new Thread(new Runnable() {
@Override
public void run() {
System.out.println("實現runable接口");
}
});
thread1.start();
//3.實現callable接口
ExecutorService service = Executors.newSingleThreadExecutor();
Future<String> future = service.submit(new Callable() {
@Override
public String call() throws Exception {
return "通過實現Callable接口";
}
});
try {
String result = future.get();
System.out.println(result);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
三種新建線程的方式具體看以上注釋,需要注意的是:
由于java不能多繼承可以實現多個接口,因此,在創建線程的時候盡量多考慮采用實現接口的形式;
實現callable接口,提交給ExecutorService返回的是異步執行的結果,另外,通常也可以利用FutureTask(Callable callable)將callable進行包裝然后FeatureTask提交給ExecutorsService。如圖,
另外由于FeatureTask也實現了Runable接口也可以利用上面第二種方式(實現Runable接口)來新建線程;
可以通過Executors將Runable轉換成Callable,具體方法是:Callable callable(Runnable task, T result), Callable callable(Runnable task)。
2、線程狀態轉換
此圖來源于《JAVA并發編程的藝術》一書中,線程是會在不同的狀態間進行轉換的,java線程線程轉換圖如上圖所示。線程創建之后調用start()方法開始運行,當調用wait(),join(),LockSupport.lock()方法線程會進入到WAITING狀態,而同樣的wait(long timeout),sleep(long),join(long),LockSupport.parkNanos(),LockSupport.parkUtil()增加了超時等待的功能,也就是調用這些方法后線程會進入TIMED_WAITING狀態,當超時等待時間到達后,線程會切換到Runable的狀態,另外當WAITING和TIMED _WAITING狀態時可以通過Object.notify(),Object.notifyAll()方法使線程轉換到Runable狀態。當線程出現資源競爭時,即等待獲取鎖的時候,線程會進入到BLOCKED阻塞狀態,當線程獲取鎖時,線程進入到Runable狀態。線程運行結束后,線程進入到TERMINATED狀態,狀態轉換可以說是線程的生命周期。另外需要注意的是:
當線程進入到synchronized方法或者synchronized代碼塊時,線程切換到的是BLOCKED狀態,而使用java.util.concurrent.locks下lock進行加鎖的時候線程切換的是WAITING或者TIMED_WAITING狀態,因為lock會調用LockSupport的方法。
用一個表格將上面六種狀態進行一個總結歸納。
3、 線程狀態的基本操作
除了新建一個線程外,線程在生命周期內還有需要基本操作,而這些操作會成為線程間一種通信方式,比如使用中斷(interrupted)方式通知實現線程間的交互等等,下面將具體說說這些操作。
(1) interrupted
中斷可以理解為線程的一個標志位,它表示了一個運行中的線程是否被其他線程進行了中斷操作。中斷好比其他線程對該線程打了一個招呼。其他線程可以調用該線程的interrupt()方法對其進行中斷操作,同時該線程可以調用 isInterrupted()來感知其他線程對其自身的中斷操作,從而做出響應。另外,同樣可以調用Thread的靜態方法 interrupted()對當前線程進行中斷操作,該方法會清除中斷標志位。需要注意的是,當拋出InterruptedException時候,會清除中斷標志位,也就是說在調用isInterrupted會返回false。
下面結合具體的實例來看一看
public class InterruptDemo {
public static void main(String[] args) throws InterruptedException {
//sleepThread睡眠1000ms
final Thread sleepThread = new Thread() {
@Override
public void run() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
super.run();
}
};
//busyThread一直執行死循環
Thread busyThread = new Thread() {
@Override
public void run() {
while (true) ;
}
};
sleepThread.start();
busyThread.start();
sleepThread.interrupt();
busyThread.interrupt();
while (sleepThread.isInterrupted()) ;
System.out.println("sleepThread isInterrupted: " + sleepThread.isInterrupted());
System.out.println("busyThread isInterrupted: " + busyThread.isInterrupted());
}
}
輸出結果
> sleepThread isInterrupted: false busyThread isInterrupted: true
開啟了兩個線程分別為sleepThread和BusyThread, sleepThread睡眠1s,BusyThread執行死循環。然后分別對著兩個線程進行中斷操作,可以看出sleepThread拋出InterruptedException后清除標志位,而busyThread就不會清除標志位。
另外,同樣可以通過中斷的方式實現線程間的簡單交互, while (sleepThread.isInterrupted()) 表示在Main中會持續監測sleepThread,一旦sleepThread的中斷標志位清零,即sleepThread.isInterrupted()返回為false時才會繼續Main線程才會繼續往下執行。因此,中斷操作可以看做線程間一種簡便的交互方式。一般在結束線程時通過中斷標志位或者標志位的方式可以有機會去清理資源,相對于武斷而直接的結束線程,這種方式要優雅和安全。
(2) join
join方法可以看做是線程間協作的一種方式,很多時候,一個線程的輸入可能非常依賴于另一個線程的輸出,這就像兩個好基友,一個基友先走在前面突然看見另一個基友落在后面了,這個時候他就會在原處等一等這個基友,等基友趕上來后,就兩人攜手并進。其實線程間的這種協作方式也符合現實生活。在軟件開發的過程中,從客戶那里獲取需求后,需要經過需求分析師進行需求分解后,這個時候產品,開發才會繼續跟進。如果一個線程實例A執行了threadB.join(),其含義是:當前線程A會等待threadB線程終止后threadA才會繼續執行。關于join方法一共提供如下這些方法:
public final synchronized void join(long millis)
public final synchronized void join(long millis, int nanos)
public final void join() throws InterruptedException
Thread類除了提供join()方法外,另外還提供了超時等待的方法,如果線程threadB在等待的時間內還沒有結束的話,threadA會在超時之后繼續執行。join方法源碼關鍵是:
while (isAlive()) {
wait(0);
}
可以看出來當前等待對象threadA會一直阻塞,直到被等待對象threadB結束后即isAlive()返回false的時候才會結束while循環,當threadB退出時會調用notifyAll()方法通知所有的等待線程。下面用一個具體的例子來說說join方法的使用:
public class JoinDemo {
public static void main(String[] args) {
Thread previousThread = Thread.currentThread();
for (int i = 1; i <= 10; i++) {
Thread curThread = new JoinThread(previousThread);
curThread.start();
previousThread = curThread;
}
}
static class JoinThread extends Thread {
private Thread thread;
public JoinThread(Thread thread) {
this.thread = thread;
}
@Override
public void run() {
try {
thread.join();
System.out.println(thread.getName() + " terminated.");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
輸出結果為:
main terminated.
Thread-0 terminated.
Thread-1 terminated.
Thread-2 terminated.
Thread-3 terminated.
Thread-4 terminated.
Thread-5 terminated.
Thread-6 terminated.
Thread-7 terminated.
Thread-8 terminated.
在上面的例子中一個創建了10個線程,每個線程都會等待前一個線程結束才會繼續運行。可以通俗的理解成接力,前一個線程將接力棒傳給下一個線程,然后又傳給下一個線程......
(3)sleep
public static native void sleep(long millis)方法顯然是Thread的靜態方法,很顯然它是讓當前線程按照指定的時間休眠,其休眠時間的精度取決于處理器的計時器和調度器。需要注意的是如果當前線程獲得了鎖,sleep方法并不會失去鎖。sleep方法經常拿來與Object.wait()方法進行比價,這也是面試經常被問的地方。
sleep() VS wait()
兩者主要的區別:
1)sleep()方法是Thread的靜態方法,而wait是Object實例方法
2) wait()方法必須要在同步方法或者同步塊中調用,也就是必須已經獲得對象鎖。而sleep()方法沒有這個限制可以在任何地方種使用。另外,wait()方法會釋放占有的對象鎖,使得該線程進入等待池中,等待下一次獲取資源。而sleep()方法只是會讓出CPU并不會釋放掉對象鎖;
3)sleep()方法在休眠時間達到后如果再次獲得CPU時間片就會繼續執行,而wait()方法必須等待Object.notift/Object.notifyAll通知后,才會離開等待池,并且再次獲得CPU時間片才會繼續執行。
(4)yield
public static native void yield();這是一個靜態方法,一旦執行,它會是當前線程讓出CPU,但是,需要注意的是,讓出的CPU并不是代表當前線程不再運行了,如果在下一次競爭中,又獲得了CPU時間片當前線程依然會繼續運行。另外,讓出的時間片只會分配給當前線程相同優先級的線程。什么是線程優先級了?下面就來具體聊一聊。
現代操作系統基本采用時分的形式調度運行的線程,操作系統會分出一個個時間片,線程會分配到若干時間片,當前時間片用完后就會發生線程調度,并等待這下次分配。線程分配到的時間多少也就決定了線程使用處理器資源的多少,而線程優先級就是決定線程需要或多或少分配一些處理器資源的線程屬性。
在Java程序中,通過一個整型成員變量Priority來控制優先級,優先級的范圍從1~10.在構建線程的時候可以通過setPriority(int)方法進行設置,默認優先級為5,優先級高的線程相較于優先級低的線程優先獲得處理器時間片。需要注意的是在不同JVM以及操作系統上,線程規劃存在差異,有些操作系統甚至會忽略線程優先級的設定。
另外需要注意的是,sleep()和yield()方法,同樣都是當前線程會交出處理器資源,而它們不同的是,sleep()交出來的時間片其他線程都可以去競爭,也就是說都有機會獲得當前線程讓出的時間片。而yield()方法只允許與當前線程具有相同優先級的線程能夠獲得釋放出來的CPU時間片。
4、守護線程Daemon
守護線程是一種特殊的線程,就和它的名字一樣,它是系統的守護者,在后臺默默地守護一些系統服務,比如垃圾回收線程,JIT線程就可以理解守護線程。與之對應的就是用戶線程,用戶線程就可以認為是系統的工作線程,它會完成整個系統的業務操作。用戶線程完全結束后就意味著整個系統的業務任務全部結束了,因此系統就沒有對象需要守護的了,守護線程自然而然就會退。當一個Java應用,只有守護線程的時候,虛擬機就會自然退出。下面以一個簡單的例子來表述Daemon線程的使用。
public class DaemonDemo {
public static void main(String[] args) {
Thread daemonThread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
System.out.println("i am alive");
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
System.out.println("finally block");
}
}
}
});
daemonThread.setDaemon(true);
daemonThread.start();
//確保main線程結束前能給daemonThread能夠分到時間片
try {
Thread.sleep(800);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
輸出結果為:
> i am alive finally block i am alive
上面的例子中daemodThread
run方法中是一個while死循環,會一直打印,但是當main線程結束后daemonThread就會退出所以不會出現死循環的情況。main線程先睡眠800ms保證daemonThread能夠擁有一次時間片的機會,也就是說可以正常執行一次打印“i
am alive”操作和一次finally塊中"finally block"操作。緊接著main 線程結束后,daemonThread退出,這個時候只打印了"i
am
alive"并沒有打印finnal塊中的。因此,這里需要注意的是守護線程在退出的時候并不會執行finnaly塊中的代碼,所以將釋放資源等操作不要放在finnaly塊中執行,這種操作是不安全的。
線程可以通過setDaemon(true)的方法將線程設置為守護線程。并且需要注意的是設置守護線程要先于start()方法,否則會報。
Exception in thread "main" java.lang.IllegalThreadStateException at java.lang.Thread.setDaemon(Thread.java:1365) at learn.DaemonDemo.main(DaemonDemo.java:19)
這樣的異常,但是該線程還是會執行,只不過會當做正常的用戶線程執行。
以上就是動力節點java學院小編介紹的“java多線程的狀態轉換以及基本操作”的內容,希望對大家有幫助,如有疑問,請在線咨詢,有專業老師隨時為你服務。
0基礎 0學費 15天面授
有基礎 直達就業
業余時間 高薪轉行
工作1~3年,加薪神器
工作3~5年,晉升架構
提交申請后,顧問老師會電話與您溝通安排學習