詳解Java多線程編程中LockSupport類的線程壅塞用法。本站提示廣大學習愛好者:(詳解Java多線程編程中LockSupport類的線程壅塞用法)文章只能為提供參考,不一定能成為您想要的結果。以下是詳解Java多線程編程中LockSupport類的線程壅塞用法正文
LockSupport是用來創立鎖和其他同步類的根本線程壅塞原語。
LockSupport中的park() 和 unpark() 的感化分離是壅塞線程息爭除壅塞線程,並且park()和unpark()不會碰到“Thread.suspend 和 Thread.resume所能夠激發的逝世鎖”成績。
由於park() 和 unpark()有允許的存在;挪用 park() 的線程和另外一個試圖將其 unpark() 的線程之間的競爭將堅持活性。
根本用法
LockSupport 很相似於二元旌旗燈號量(只要1個允許證可供應用),假如這個允許還沒有被占用,以後線程獲得允許並繼 續 履行;假如允許曾經被占用,以後線 程壅塞,期待獲得允許。
public static void main(String[] args)
{
LockSupport.park();
System.out.println("block.");
}
運轉該代碼,可以發明主線程一向處於壅塞狀況。由於 允許默許是被占用的 ,挪用park()時獲得不到允許,所以進入壅塞狀況。
以下代碼:先釋放允許,再獲得允許,主線程可以或許正常終止。LockSupport允許的獲得和釋放,普通來講是對應的,假如屢次unpark,只要一次park也不會湧現甚麼成績,成果是允許處於可用狀況。
public static void main(String[] args)
{
Thread thread = Thread.currentThread();
LockSupport.unpark(thread);//釋放允許
LockSupport.park();// 獲得允許
System.out.println("b");
}
LockSupport是可不重入 的,假如一個線程持續2次挪用 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,由於第二次挪用park的時刻,線程沒法獲得允許湧現逝世鎖。
上面我們來看下LockSupport對應中止的呼應性
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。這解釋 線程假如由於挪用park而壅塞的話,可以或許呼應中止要求(中止狀況被設置成true),然則不會拋出InterruptedException 。
LockSupport函數列表
// 前往供給給比來一次還沒有消除壅塞的 park 辦法挪用的 blocker 對象,假如該挪用不受壅塞,則前往 null。 static Object getBlocker(Thread t) // 為了線程調劑,禁用以後線程,除非允許可用。 static void park() // 為了線程調劑,在允許可用之前禁用以後線程。 static void park(Object blocker) // 為了線程調劑禁用以後線程,最多期待指定的期待時光,除非允許可用。 static void parkNanos(long nanos) // 為了線程調劑,在允許可用前禁用以後線程,並最多期待指定的期待時光。 static void parkNanos(Object blocker, long nanos) // 為了線程調劑,在指定的時限前禁用以後線程,除非允許可用。 static void parkUntil(long deadline) // 為了線程調劑,在指定的時限前禁用以後線程,除非允許可用。 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)獲得“以後對象的同步鎖”
System.out.println(Thread.currentThread().getName()+" wakup others");
notify(); // 叫醒“以後對象上的期待線程”
}
}
}
}
示例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);
}
}
}
運轉成果:
main start ta main block ta wakup others main continue
解釋:park和wait的差別。wait讓線程壅塞前,必需經由過程synchronized獲得同步鎖。