程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> 詳解Java多線程編程中LockSupport類的線程壅塞用法

詳解Java多線程編程中LockSupport類的線程壅塞用法

編輯:關於JAVA

詳解Java多線程編程中LockSupport類的線程壅塞用法。本站提示廣大學習愛好者:(詳解Java多線程編程中LockSupport類的線程壅塞用法)文章只能為提供參考,不一定能成為您想要的結果。以下是詳解Java多線程編程中LockSupport類的線程壅塞用法正文


LockSupport是用來創立鎖和其他同步類的根本線程壅塞原語。
LockSupport中的park() 和 unpark() 的感化分離是壅塞線程息爭除壅塞線程,並且park()和unpark()不會碰到“Thread.suspend 和 Thread.resume所能夠激發的逝世鎖”成績。
由於park() 和 unpark()有允許的存在;挪用 park() 的線程和另外一個試圖將其 unpark() 的線程之間的競爭將堅持活性。

根本用法
LockSupport 很相似於二元旌旗燈號量(只要1個允許證可供應用),假如這個允許還沒有被占用,以後線程獲得允許並繼 續 履行;假如允許曾經被占用,以後線 程壅塞,期待獲得允許。

public static void main(String[] args)
{
   LockSupport.park();
   System.out.println("block.");
}

運轉該代碼,可以發明主線程一向處於壅塞狀況。由於 允許默許是被占用的 ,挪用park()時獲得不到允許,所以進入壅塞狀況。

以下代碼:先釋放允許,再獲得允許,主線程可以或許正常終止。LockSupport允許的獲得和釋放,普通來講是對應的,假如屢次unpark,只要一次park也不會湧現甚麼成績,成果是允許處於可用狀況。

public static void main(String[] args)
{
   Thread thread = Thread.currentThread();
   LockSupport.unpark(thread);//釋放允許
   LockSupport.park();// 獲得允許
   System.out.println("b");
}

LockSupport是可不重入 的,假如一個線程持續2次挪用 LockSupport .park(),那末該線程必定會一向壅塞下去。

public static void main(String[] args) throws Exception
{
 Thread thread = Thread.currentThread();
 
 LockSupport.unpark(thread);
 
 System.out.println("a");
 LockSupport.park();
 System.out.println("b");
 LockSupport.park();
 System.out.println("c");
}

這段代碼打印出a和b,不會打印c,由於第二次挪用park的時刻,線程沒法獲得允許湧現逝世鎖。

上面我們來看下LockSupport對應中止的呼應性

public static void t2() throws Exception
{
 Thread t = new Thread(new Runnable()
 {
  private int count = 0;

  @Override
  public void run()
  {
   long start = System.currentTimeMillis();
   long end = 0;

   while ((end - start) <= 1000)
   {
    count++;
    end = System.currentTimeMillis();
   }

   System.out.println("after 1 second.count=" + count);

  //期待也許允許
   LockSupport.park();
   System.out.println("thread over." + Thread.currentThread().isInterrupted());

  }
 });

 t.start();

 Thread.sleep(2000);

 // 中止線程
 t.interrupt();

 
 System.out.println("main over");
}

終究線程會打印出thread over.true。這解釋 線程假如由於挪用park而壅塞的話,可以或許呼應中止要求(中止狀況被設置成true),然則不會拋出InterruptedException 。

LockSupport函數列表

// 前往供給給比來一次還沒有消除壅塞的 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

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);
    }
  }
}

運轉成果:

main start ta
main block
ta wakup others
main continue

解釋:park和wait的差別。wait讓線程壅塞前,必需經由過程synchronized獲得同步鎖。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved