快捷導航

Java concurrency之LockSupport_動力節(jié)點Java學院整理

更新時間：2017年06月12日 15:21:33 作者：skywang12345

這篇文章主要為大家詳細介紹了Java concurrency之LockSupport的相關(guān)資料，具有一定的參考價值，感興趣的小伙伴們可以參考一下

LockSupport介紹

LockSupport是用來創(chuàng)建鎖和其他同步類的基本線程阻塞原語。
LockSupport中的park() 和 unpark() 的作用分別是阻塞線程和解除阻塞線程，而且park()和unpark()不會遇到“Thread.suspend 和 Thread.resume所可能引發(fā)的死鎖”問題。
因為park() 和 unpark()有許可的存在；調(diào)用 park() 的線程和另一個試圖將其 unpark() 的線程之間的競爭將保持活性。

LockSupport函數(shù)列表

// 返回提供給最近一次尚未解除阻塞的 park 方法調(diào)用的 blocker 對象，如果該調(diào)用不受阻塞，則返回 null。
static Object getBlocker(Thread t)
// 為了線程調(diào)度，禁用當前線程，除非許可可用。
static void park()
// 為了線程調(diào)度，在許可可用之前禁用當前線程。
static void park(Object blocker)
// 為了線程調(diào)度禁用當前線程，最多等待指定的等待時間，除非許可可用。
static void parkNanos(long nanos)
// 為了線程調(diào)度，在許可可用前禁用當前線程，并最多等待指定的等待時間。
static void parkNanos(Object blocker, long nanos)
// 為了線程調(diào)度，在指定的時限前禁用當前線程，除非許可可用。
static void parkUntil(long deadline)
// 為了線程調(diào)度，在指定的時限前禁用當前線程，除非許可可用。
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);
    }
  }
}

運行結(jié)果：

main start ta
main block
ta wakup others
main continue

說明：park和wait的區(qū)別。wait讓線程阻塞前，必須通過synchronized獲取同步鎖。

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: