詳解Java多線程編程中LockSupport類的線程阻塞用法
LockSupport是用來創(chuàng)建鎖和其他同步類的基本線程阻塞原語。
LockSupport中的park() 和 unpark() 的作用分別是阻塞線程和解除阻塞線程，而且park()和unpark()不會遇到“Thread.suspend 和 Thread.resume所可能引發(fā)的死鎖”問題。
因?yàn)閜ark() 和 unpark()有許可的存在；調(diào)用 park() 的線程和另一個(gè)試圖將其 unpark() 的線程之間的競爭將保持活性。
基本用法
LockSupport 很類似于二元信號量(只有1個(gè)許可證可供使用)，如果這個(gè)許可還沒有被占用，當(dāng)前線程獲取許可并繼 續(xù) 執(zhí)行；如果許可已經(jīng)被占用，當(dāng)前線 程阻塞，等待獲取許可。
public static void main(String[] args)
{
LockSupport.park();
System.out.println("block.");
}
運(yùn)行該代碼，可以發(fā)現(xiàn)主線程一直處于阻塞狀態(tài)。因?yàn)?許可默認(rèn)是被占用的 ，調(diào)用park()時(shí)獲取不到許可，所以進(jìn)入阻塞狀態(tài)。
如下代碼：先釋放許可，再獲取許可，主線程能夠正常終止。LockSupport許可的獲取和釋放，一般來說是對應(yīng)的，如果多次unpark，只有一次park也不會出現(xiàn)什么問題，結(jié)果是許可處于可用狀態(tài)。
public static void main(String[] args)
{
Thread thread = Thread.currentThread();
LockSupport.unpark(thread);//釋放許可
LockSupport.park();// 獲取許可
System.out.println("b");
}
LockSupport是可不重入 的，如果一個(gè)線程連續(xù)2次調(diào)用 LockSupport .park()，那么該線程一定會一直阻塞下去。
public static void main(String[] args) throws Exception
{
Thread thread = Thread.currentThread();
LockSupport.unpark(thread);
System.out.println("a");
LockSupport.park();
System.out.println("b");
LockSupport.park();
System.out.println("c");
}
這段代碼打印出a和b，不會打印c，因?yàn)榈诙握{(diào)用park的時(shí)候，線程無法獲取許可出現(xiàn)死鎖。
下面我們來看下LockSupport對應(yīng)中斷的響應(yīng)性
public static void t2() throws Exception
{
Thread t = new Thread(new Runnable()
{
private int count = 0;
@Override
public void run()
{
long start = System.currentTimeMillis();
long end = 0;
while ((end - start) <= 1000)
{
count++;
end = System.currentTimeMillis();
}
System.out.println("after 1 second.count=" + count);
//等待或許許可
LockSupport.park();
System.out.println("thread over." + Thread.currentThread().isInterrupted());
}
});
t.start();
Thread.sleep(2000);
// 中斷線程
t.interrupt();
System.out.println("main over");
}
最終線程會打印出thread over.true。這說明 線程如果因?yàn)檎{(diào)用park而阻塞的話，能夠響應(yīng)中斷請求(中斷狀態(tài)被設(shè)置成true)，但是不會拋出InterruptedException 。
LockSupport函數(shù)列表
// 返回提供給最近一次尚未解除阻塞的 park 方法調(diào)用的 blocker 對象，如果該調(diào)用不受阻塞，則返回 null。 static Object getBlocker(Thread t) // 為了線程調(diào)度，禁用當(dāng)前線程，除非許可可用。 static void park() // 為了線程調(diào)度，在許可可用之前禁用當(dāng)前線程。 static void park(Object blocker) // 為了線程調(diào)度禁用當(dāng)前線程，最多等待指定的等待時(shí)間，除非許可可用。 static void parkNanos(long nanos) // 為了線程調(diào)度，在許可可用前禁用當(dāng)前線程，并最多等待指定的等待時(shí)間。 static void parkNanos(Object blocker, long nanos) // 為了線程調(diào)度，在指定的時(shí)限前禁用當(dāng)前線程，除非許可可用。 static void parkUntil(long deadline) // 為了線程調(diào)度，在指定的時(shí)限前禁用當(dāng)前線程，除非許可可用。 static void parkUntil(Object blocker, long deadline) // 如果給定線程的許可尚不可用，則使其可用。 static void unpark(Thread thread)
LockSupport示例
對比下面的“示例1”和“示例2”可以更清晰的了解LockSupport的用法。
示例1
public class WaitTest1 {
public static void main(String[] args) {
ThreadA ta = new ThreadA("ta");
synchronized(ta) { // 通過synchronized(ta)獲取“對象ta的同步鎖”
try {
System.out.println(Thread.currentThread().getName()+" start ta");
ta.start();
System.out.println(Thread.currentThread().getName()+" block");
// 主線程等待
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) { // 通過synchronized(this)獲取“當(dāng)前對象的同步鎖”
System.out.println(Thread.currentThread().getName()+" wakup others");
notify(); // 喚醒“當(dāng)前對象上的等待線程”
}
}
}
}
示例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");
// 獲取主線程
mainThread = Thread.currentThread();
System.out.println(Thread.currentThread().getName()+" start ta");
ta.start();
System.out.println(Thread.currentThread().getName()+" block");
// 主線程阻塞
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");
// 喚醒“主線程”
LockSupport.unpark(mainThread);
}
}
}
運(yùn)行結(jié)果：
main start ta main block ta wakup others main continue
說明：park和wait的區(qū)別。wait讓線程阻塞前，必須通過synchronized獲取同步鎖。
相關(guān)文章
Java異步判斷線程池所有任務(wù)是否執(zhí)行完成的操作方法
這篇文章主要介紹了Java異步判斷線程池所有任務(wù)是否執(zhí)行完成的方法,在這個(gè)示例中,我使用了傳統(tǒng)的匿名內(nèi)部類來創(chuàng)建Callable任務(wù)（同時(shí)也提供了Lambda表達(dá)式的注釋）,以便與各種Java版本兼容,需要的朋友可以參考下2024-07-07
Java實(shí)現(xiàn)導(dǎo)入csv的示例代碼
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)導(dǎo)入csv的相關(guān)知識,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,有需要的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03
解決java main函數(shù)中的args數(shù)組傳值問題
這篇文章主要介紹了解決java main函數(shù)中的args數(shù)組傳值問題，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-02-02
這篇文章主要為大家詳細(xì)介紹了常見的java面試題,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-11-11
Mybatis plus結(jié)合springboot使用
本文主要介紹了MyBatisPlus使用SpringBoot數(shù)據(jù)庫操作,從添加依賴到測試,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-11-11
淺談Java中常用數(shù)據(jù)結(jié)構(gòu)的實(shí)現(xiàn)類 Collection和Map
下面小編就為大家?guī)硪黄獪\談Java中常用數(shù)據(jù)結(jié)構(gòu)的實(shí)現(xiàn)類 Collection和Map。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2016-09-09
這篇文章主要介紹了Java獲取上月份最后一天日期8位,需要的朋友可以參考下2022-09-09
在項(xiàng)目開發(fā)中,版本不一致常見問題,首先,應(yīng)檢查本地JDK版本,使用命令java-version,其次,核對項(xiàng)目及模塊版本,若有不一致,通過修改pom.xml文件同步版本,重新下載依賴即可解決問題,這種方法簡單有效,適用于多種開發(fā)環(huán)境2024-10-10
Spring注解@EnableWebMvc使用的坑點(diǎn)及解析
這篇文章主要介紹了Spring注解@EnableWebMvc使用的坑點(diǎn)及解析，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-09-09
Java+MyBatis+MySQL開發(fā)環(huán)境搭建流程詳解
Java的MyBatis框架提供了強(qiáng)大的數(shù)據(jù)庫操作支持,這里我們先在本地的開發(fā)環(huán)境中上手,來看一下Java+MyBatis+MySQL開發(fā)環(huán)境搭建流程詳2016-06-06