LockSupportBlockerTest.java

package com.javaedge.concurrency;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

public class LockSupportBlockerTest {
    public static void main(String[] args) {
        Thread t3 = new Thread(() -> {    
            Thread.currentThread().setName("t3");
            System.out.println(Thread.currentThread().getName() + " park 5 seconds");
            //park 5 seconds, set blocker
            Object blocker = new String("JavaEdge");
            LockSupport.parkUntil(blocker, System.currentTimeMillis() + TimeUnit.MILLISECONDS.convert(5, TimeUnit.SECONDS));
            System.out.println(Thread.currentThread().getName() + " after park");
        });
        t3.start();

        try {
            Object t3_blocker = null;
            while (t3_blocker == null) {
                t3_blocker = LockSupport.getBlocker(t3);
                TimeUnit.MILLISECONDS.sleep(10);
            }
            System.out.println("t3 blocker is :" + t3_blocker);
            t3.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}