LockSupport是用來(lái)創(chuàng)建鎖和其他同步類的基本線程阻塞原語(yǔ)。
LockSupport中的park() 和 unpark() 的作用分別是阻塞線程和解除阻塞線程，而且park()和unpark()不會(huì)遇到“Thread.suspend 和 Thread.resume所可能引發(fā)的死鎖”問(wèn)題。
因?yàn)閜ark() 和 unpark()有許可的存在；調(diào)用 park() 的線程和另一個(gè)試圖將其 unpark() 的線程之間的競(jìng)爭(zhēng)將保持活性。
LockSupport函數(shù)列表
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
// 返回提供給最近一次尚未解除阻塞的 park 方法調(diào)用的 blocker 對(duì)象，如果該調(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示例
對(duì)比下面的“示例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) { // 通過(guò)synchronized(ta)獲取“對(duì)象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) { // 通過(guò)synchronized(this)獲取“當(dāng)前對(duì)象的同步鎖” System.out.println(Thread.currentThread().getName()+" wakup others"); notify(); // 喚醒“當(dāng)前對(duì)象上的等待線程” } } }} |
示例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); } }} |
運(yùn)行結(jié)果：
main start ta
main block
ta wakup others
main continue
說(shuō)明：park和wait的區(qū)別。wait讓線程阻塞前，必須通過(guò)synchronized獲取同步鎖。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
