快捷導航

JAVA線程sleep()和wait()詳解及實例

更新時間：2017年05月12日 09:48:01 投稿：lqh

這篇文章主要介紹了JAVA線程sleep()和wait()詳解及實例的相關(guān)資料,探討一下sleep（）和wait（）方法的區(qū)別和實現(xiàn)機制，需要的朋友可以參考下

JAVA線程sleep()和wait()詳解及實例

sleep

1.sleep是Thread的一個靜態(tài)（static）方法。使得Runnable實現(xiàn)的線程也可以使用sleep方法。而且避免了線程之前相互調(diào)用sleep()方法，引發(fā)死鎖。

2.sleep()執(zhí)行時需要賦予一個沉睡時間。在沉睡期間（阻塞線程期間），CPU會放棄這個線程，執(zhí)行其他任務(wù)。當沉睡時間到了之后，該線程會自動蘇醒，不過此時線程不會立刻被執(zhí)行，而是要等CPU分配資源，和其他線程進行競爭。

3.此外如果這個線程之前獲取了一個機鎖，在沉睡期間，這個機鎖不會釋放。其他等待這個機鎖的程序，必須等待這個線程醒來，且執(zhí)行完后才能運行。

sleep相關(guān)代碼

public class ThreadTest2 {

  public static void main(String[] args){
    System.out.println("begin our test");
    ThreadSleep sleep = new ThreadSleep();
    try {
      Thread thread1 = new Thread(sleep,"路人甲");
      Thread thread2 = new Thread(sleep,"路人乙");
      thread1.start();
      thread2.start();
    }catch(Exception e){
      e.printStackTrace();
    }
    System.out.println("test is over");
  }


}

 class ThreadSleep implements Runnable{

   int count = 0;

   @Override
   public void run(){
     System.out.println(Thread.currentThread().getName() + " say : hello sleep !!");
     count();

   }

   public void count(){
     while(count < 20) {
         System.out.println(Thread.currentThread().getName() + " say : count is " + count);
         try {
           count++;
           Thread.sleep(100);
         } catch (Exception e) {
           e.printStackTrace();
         }
     }

   }
}

輸出日志

begin our test
test is over
路人甲 say : hello sleep !!
路人甲 say : count is 0
路人乙 say : hello sleep !!
路人乙 say : count is 1
路人甲 say : count is 2
路人乙 say : count is 2
路人甲 say : count is 4
路人乙 say : count is 4
路人甲 say : count is 6
路人乙 say : count is 7
路人乙 say : count is 8
路人甲 say : count is 8
路人甲 say : count is 10
路人乙 say : count is 10
路人乙 say : count is 12
路人甲 say : count is 12
路人乙 say : count is 14
路人甲 say : count is 14
路人甲 say : count is 16
路人乙 say : count is 16
路人甲 say : count is 18
路人乙 say : count is 18

通過日志可以發(fā)現(xiàn)線程甲和線程乙基本是交替執(zhí)行，但是并不規(guī)律，且出現(xiàn)了并發(fā)問題。

該情況是由于代碼中設(shè)置了睡眠時間為100毫秒，由于count遞增執(zhí)行速度很快，所以線程差不多是同時睡眠，然后同時蘇醒并導致了并發(fā)的出現(xiàn)。

接下來要添加synchronize塊，檢查sleep時機鎖是否釋放

public class ThreadTest2 {

  public static void main(String[] args){
    System.out.println("begin our test");
    ThreadSleep sleep = new ThreadSleep();
    try {
      Thread thread1 = new Thread(sleep,"路人甲");
      Thread thread2 = new Thread(sleep,"路人乙");
      thread1.start();
      thread2.start();
    }catch(Exception e){
      e.printStackTrace();
    }
    System.out.println("test is over");
  }


}

class ThreadSleep implements Runnable{

  int count = 0;

  @Override
  public void run(){
    System.out.println(Thread.currentThread().getName() + " say : hello sleep !!");
    count();

  }

  public void count(){
    while(count < 20) {
      synchronized (this) {
        System.out.println(Thread.currentThread().getName() + " say : count is " + count);
        try {
          count++;
          Thread.sleep(100);
        } catch (Exception e) {
          e.printStackTrace();
        }

      }
    }

  }
}

輸出日志

begin our test
路人甲 say : hello sleep !!
路人甲 say : count is 0
test is over
路人乙 say : hello sleep !!
路人甲 say : count is 1
路人甲 say : count is 2
路人甲 say : count is 3
路人甲 say : count is 4
路人甲 say : count is 5
路人甲 say : count is 6
路人甲 say : count is 7
路人甲 say : count is 8
路人甲 say : count is 9
路人甲 say : count is 10
路人甲 say : count is 11
路人甲 say : count is 12
路人甲 say : count is 13
路人甲 say : count is 14
路人甲 say : count is 15
路人甲 say : count is 16
路人甲 say : count is 17
路人甲 say : count is 18
路人甲 say : count is 19
路人乙 say : count is 20

通過日志可以看出，基本是線程甲在執(zhí)行，這是因為sleep時，機鎖一直在線程甲上，所以線程乙只能一直等待直到線程甲釋放鎖。

wait

1.wait()是Object類的一個方法。當調(diào)用wait()方法時，該線程會進入和該對象相關(guān)的等待池中，并釋放它所擁有的機鎖。

2.執(zhí)行wait()后，必須使用notify()方法或notifyAll()方法或設(shè)置等待時間(wait(long time))喚醒在等待線程池中的線程。

3.wait()必須放在synchronized block中，否則會在運行時報“java.lang.IllegalMonitorStateException”異常

wait相關(guān)代碼

public class ThreadTest2 {

  public static void main(String[] args) {
    System.out.println("begin our test");
    ThreadSleep sleep = new ThreadSleep();
    try {
      Thread thread1 = new Thread(sleep, "路人甲");
      Thread thread2 = new Thread(sleep, "路人乙");
      thread1.start();
      thread2.start();
    } catch (Exception e) {
      e.printStackTrace();
    }
    System.out.println("test is over");
  }
}

class ThreadSleep implements Runnable {

  int count = 0;

  @Override
  public void run() {
    System.out.println(Thread.currentThread().getName() + " say : hello sleep !!");
    count();

  }

  public void count() {
    while (count < 20) {
      synchronized (this) {
        System.out.println(Thread.currentThread().getName() + " say : count is " + count);
        try {
          count++;
          this.wait(100);
        } catch (Exception e) {
          e.printStackTrace();
        }
      }
    }

  }
}

輸出日志

begin our test
路人甲 say : hello sleep !!
路人甲 say : count is 0
test is over
路人乙 say : hello sleep !!
路人乙 say : count is 1
路人甲 say : count is 2
路人乙 say : count is 3
路人甲 say : count is 4
路人乙 say : count is 5
路人甲 say : count is 6
路人乙 say : count is 7
路人甲 say : count is 8
路人乙 say : count is 9
路人甲 say : count is 10
路人乙 say : count is 11
路人甲 say : count is 12
路人乙 say : count is 13
路人乙 say : count is 14
路人甲 say : count is 15
路人乙 say : count is 16
路人甲 say : count is 17
路人乙 say : count is 18
路人甲 say : count is 19

通過日志可以發(fā)現(xiàn)在wait的情況下，機鎖會被釋放。

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

您可能感興趣的文章: