LockSupport是用來創建鎖和其他同步類的基本線程阻塞原語。
LockSupport中的park() 和 unpark() 的作用分別是阻塞線程和解除阻塞線程，而且park()和unpark()不會遇到“Thread.suspend 和 Thread.resume所可能引發的死鎖”問題。
因為park() 和 unpark()有許可的存在；調用 park() 的線程和另一個試圖將其 unpark() 的線程之間的競爭將保持活性。
LockSupport函數列表
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
// 返回提供給最近一次尚未解除阻塞的 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
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獲取同步鎖。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
