Java并发编程之 park & unpark 方法

青旅半醒 2022-11-10 10:41 105阅读 0赞

## park & unpark ##

### 文章目录 ###

*   *  park & unpark
     *   *  1 基本使用
         *  2 park & unpark 原理
         *   *  先调用park再调用unpark的过程
             *  先调用unpark再调用park的过程

### 1 基本使用 ###

它们是 LockSupport 类中的方法

// 暂停当前线程，在哪个线程中调用就对哪个线程进行操作，此线程进入wait状态（阻塞状态）
    LockSupport.park();
    
    // 恢复某个线程的运行，参数中传递需要恢复的线程
    // unpark方法可以在park之前 / 之后调用，都可以恢复线程
    LockSupport.unpark(Thread thread);

**代码示例**

@Slf4j(topic = "c.TestParkUnpark")
    public class TestParkUnpark { 
        public static void main(String[] args) { 
            Thread t1 = new Thread(() -> { 
                log.debug("start...");
                sleep(1);
                log.debug("park...");
                LockSupport.park();
                log.debug("resume...");
            }, "t1");
            t1.start();
    
            sleep(2);
            log.debug("unpark...");
            LockSupport.unpark(t1);
        }
    }

运行结果

![2021031621134344.png][]

即使两个线程的sleep时间互换，t1仍然可以被恢复

**与wait/notify对比**

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-PU7aSvC2-1615900364816)(图片/java并发1/image-20210316204054649.png)\]][img-PU7aSvC2-1615900364816_java_1_image-20210316204054649.png]

### 2 park & unpark 原理 ###

每个线程都有自己的一个 Parker 对象，由三部分组成 \_counter， \_cond和 \_mutex

1.  打个比喻线程就像一个旅人，Parker 就像他随身携带的背包，条件变量 \_ cond就好比背包中的帐篷。\_counter 就好比背包中的备用干粮（0 为耗尽，1 为充足）
2.  调用 park 就是要看需不需要停下来歇息
    
    1.  如果备用干粮耗尽，那么钻进帐篷歇息
    2.  如果备用干粮充足，那么不需停留，继续前进
3.  调用 unpark，就好比令干粮充足，将\_counter设置为1，有两种情况
    
    1.  如果这时线程还在帐篷\_cond，就将\_counter设置为1，让其充足，唤醒让他继续前进
    2.  如果这时线程还在运行，就将\_counter设置为1，那么下次他调用 park 时，仅是消耗掉备用干粮，不需停留继续前进
        
         *  因为背包空间有限，多次调用 unpark 仅会补充一份备用干粮，将\_counter设置为1

#### 先调用park再调用unpark的过程 ####

1.先调用park

1.  当前线程调用 park() 方法
2.  检查 \_counter ，本情况为 0，这时，获得 \_mutex 互斥锁(mutex对象有个等待队列 \_cond)
3.  线程进入 \_cond 条件变量阻塞
4.  设置 \_counter = 0（即使已经为0，还要再设置一次为0）

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ccJMHXgz-1615900364819)(图片/java并发1/image-20210316205539202.png)\]][img-ccJMHXgz-1615900364819_java_1_image-20210316205539202.png]

2.调用unpark

1.  调用 Unsafe.unpark(Thread\_0) 方法，设置 \_counter 为 1
2.  唤醒 \_cond 条件变量中的 Thread\_0
3.  Thread\_0 恢复运行
4.  设置 \_counter 为 0

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-iAeSGJta-1615900364821)(图片/java并发1/image-20210316205723908.png)\]][img-iAeSGJta-1615900364821_java_1_image-20210316205723908.png]

#### 先调用unpark再调用park的过程 ####

1.  调用 Unsafe.unpark(Thread\_0) 方法，设置 \_counter 为 1
2.  当前线程调用 Unsafe.park() 方法
3.  检查 \_counter ，本情况为 1，这时线程无需阻塞，继续运行
4.  设置 \_counter 为 0

![\[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ftWAr01I-1615900364824)(图片/java并发1/image-20210316205919614.png)\]][img-ftWAr01I-1615900364824_java_1_image-20210316205919614.png]

[2021031621134344.png]: /images/20221023/ccb15ddfc16746cda0679ddfacdf9a81.png
[img-PU7aSvC2-1615900364816_java_1_image-20210316204054649.png]: /images/20221023/7eb4fd28c9924b70a188d8809aac6326.png
[img-ccJMHXgz-1615900364819_java_1_image-20210316205539202.png]: /images/20221023/513df390c9494c6b89488558c0b11b7d.png
[img-iAeSGJta-1615900364821_java_1_image-20210316205723908.png]: /images/20221023/9c593196e2f4422ca96f9c21eecdb9c0.png
[img-ftWAr01I-1615900364824_java_1_image-20210316205919614.png]: /images/20221023/d68487847a634019abc848c0418ab037.png