這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)深入淺析Java 中的LockSupport,文章內(nèi)容豐富且以專(zhuān)業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
公司主營(yíng)業(yè)務(wù):成都網(wǎng)站建設(shè)、成都網(wǎng)站制作、移動(dòng)網(wǎng)站開(kāi)發(fā)等業(yè)務(wù)。幫助企業(yè)客戶(hù)真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳,提高企業(yè)的競(jìng)爭(zhēng)能力。成都創(chuàng)新互聯(lián)是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開(kāi)放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化,感謝他們對(duì)我們的高要求,感謝他們從不同領(lǐng)域給我們帶來(lái)的挑戰(zhàn),讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶(hù)帶來(lái)驚喜。成都創(chuàng)新互聯(lián)推出集賢免費(fèi)做網(wǎng)站回饋大家。
LockSupport介紹
LockSupport是用來(lái)創(chuàng)建鎖和其他同步類(lèi)的基本線(xiàn)程阻塞原語(yǔ)。
LockSupport中的park() 和 unpark() 的作用分別是阻塞線(xiàn)程和解除阻塞線(xiàn)程,而且park()和unpark()不會(huì)遇到“Thread.suspend 和 Thread.resume所可能引發(fā)的死鎖”問(wèn)題。
因?yàn)閜ark() 和 unpark()有許可的存在;調(diào)用 park() 的線(xiàn)程和另一個(gè)試圖將其 unpark() 的線(xiàn)程之間的競(jìng)爭(zhēng)將保持活性。
LockSupport函數(shù)列表
// 返回提供給最近一次尚未解除阻塞的 park 方法調(diào)用的 blocker 對(duì)象,如果該調(diào)用不受阻塞,則返回 null。 static Object getBlocker(Thread t) // 為了線(xiàn)程調(diào)度,禁用當(dāng)前線(xiàn)程,除非許可可用。 static void park() // 為了線(xiàn)程調(diào)度,在許可可用之前禁用當(dāng)前線(xiàn)程。 static void park(Object blocker) // 為了線(xiàn)程調(diào)度禁用當(dāng)前線(xiàn)程,最多等待指定的等待時(shí)間,除非許可可用。 static void parkNanos(long nanos) // 為了線(xiàn)程調(diào)度,在許可可用前禁用當(dāng)前線(xiàn)程,并最多等待指定的等待時(shí)間。 static void parkNanos(Object blocker, long nanos) // 為了線(xiàn)程調(diào)度,在指定的時(shí)限前禁用當(dāng)前線(xiàn)程,除非許可可用。 static void parkUntil(long deadline) // 為了線(xiàn)程調(diào)度,在指定的時(shí)限前禁用當(dāng)前線(xiàn)程,除非許可可用。 static void parkUntil(Object blocker, long deadline) // 如果給定線(xiàn)程的許可尚不可用,則使其可用。 static void unpark(Thread thread)
LockSupport示例
對(duì)比下面的“示例1”和“示例2”可以更清晰的了解LockSupport的用法。
示例1
public class WaitTest1 { public static void main(String[] args) { ThreadA ta = new ThreadA("ta"); synchronized(ta) { // 通過(guò)synchronized(ta)獲取“對(duì)象ta的同步鎖” try { System.out.println(Thread.currentThread().getName()+" start ta"); ta.start(); System.out.println(Thread.currentThread().getName()+" block"); // 主線(xiàn)程等待 ta.wait(); System.out.println(Thread.currentThread().getName()+" continue"); } catch (InterruptedException e) { e.printStackTrace(); } } } static class ThreadA extends Thread{ public ThreadA(String name) { super(name); } public void run() { synchronized (this) { // 通過(guò)synchronized(this)獲取“當(dāng)前對(duì)象的同步鎖” System.out.println(Thread.currentThread().getName()+" wakup others"); notify(); // 喚醒“當(dāng)前對(duì)象上的等待線(xiàn)程” } } } }
示例2
import java.util.concurrent.locks.LockSupport; public class LockSupportTest1 { private static Thread mainThread; public static void main(String[] args) { ThreadA ta = new ThreadA("ta"); // 獲取主線(xiàn)程 mainThread = Thread.currentThread(); System.out.println(Thread.currentThread().getName()+" start ta"); ta.start(); System.out.println(Thread.currentThread().getName()+" block"); // 主線(xiàn)程阻塞 LockSupport.park(mainThread); System.out.println(Thread.currentThread().getName()+" continue"); } static class ThreadA extends Thread{ public ThreadA(String name) { super(name); } public void run() { System.out.println(Thread.currentThread().getName()+" wakup others"); // 喚醒“主線(xiàn)程” LockSupport.unpark(mainThread); } } }
運(yùn)行結(jié)果:
main start ta
main block
ta wakup others
main continue
說(shuō)明:park和wait的區(qū)別。wait讓線(xiàn)程阻塞前,必須通過(guò)synchronized獲取同步鎖。
上述就是小編為大家分享的深入淺析Java 中的LockSupport了,如果剛好有類(lèi)似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。