Java에서 스레드 대기 및 알림을 구현하는 방법

이 글은 주로 Java의 스레드 대기 및 알림 구현에 대한 관련 정보를 소개합니다. 이 글이 모든 사람이 이러한 기능을 익히는 데 도움이 되기를 바랍니다. 도움이 필요한 친구는

Java의 스레드 대기 및 알림 구현

을 참조하세요. 서문:

대기/알림과 관련하여 기억해야 할 핵심 사항은 다음과 같습니다.

wait(), inform() 및 informAll() 메서드는 동기화 환경 내에서 호출되어야 합니다. 스레드는 해당 개체에 대한 잠금을 소유하지 않는 한 해당 개체에 대한 대기 또는 알림 메서드를 호출할 수 없습니다.

wait(), inform(), informAll()은 모두 Object의 인스턴스 메소드입니다. 각 개체에 잠금이 있는 것처럼 각 개체에는 신호(알림)를 기다리는 스레드 목록이 있을 수 있습니다. 스레드는 객체에 대해 wait() 메서드를 실행하여 이 대기 목록을 얻습니다. 그 시점부터 객체의 inform() 메서드가 호출될 때까지 다른 명령은 실행되지 않습니다. 여러 스레드가 동일한 개체를 기다리고 있는 경우 실행을 계속하기 위해 하나의 스레드만 선택됩니다(순서가 보장되지 않음). 대기 중인 스레드가 없으면 특별한 조치가 취해지지 않습니다.

샘플 코드:

package threadwait;

public class ThreadA extends Thread{

  public int num = 0;

  public void run(){

    synchronized (this){//在此类对象上实现同步，this指代当前对象

      for(int i = 0 ; i < 3 ; ++i)

       this.num+=i;

      notifyAll();//通知所有在这个对象上等待的线程开始执行，在这里就是通知TestNotify主线程开始执行

    }

  }

  public int getNum(){

    return this.num;

  }

}

package threadwait;

 

public class TestNotify{

  public static void main(String args[]){

    ThreadA threada = new ThreadA();

    threada.start();//threada线程有执行的资格，但是还没有开始执行

    synchronized(threada){

      try{

       threada.wait();//主线程等待threada线程执行结束才开始执行

       //而且只有获得了当前threada对象的锁之后才能执行wait，就是说在同步域内才可以执行wait，执行wait后放弃对象锁

      }catch(InterruptedException e){

       e.printStackTrace();

      }

    }

    System.out.println(threada.getNum());

  }

}

동기화는 클래스 수준인 동기화(A.class) 또는 개체 수준인 동기화(this)에서 수행되거나 정적 동기화 방법일 수 있습니다. 정적 동기화 방법은 클래스 수준에 있고, 비정적 동기화 방법은 클래스 개체 수준에 있습니다. 클래스 개체에는 잠금이 획득된 경우에만 대기 작업이 수행될 수 있습니다. 출시됩니다.

추가 예제 코드는 다음과 같습니다.

package threadwait;

 

public class ThreadA extends Thread{

  public int num = 0;

  public void run(){

    synchronized (this){//在此类对象上实现同步，this指代当前对象

      for(int i = 0 ; i < 3 ; ++i)

       this.num+=i;

      try{

       Thread.sleep(500);//如果ThreadB的三个示例线程在还没有进入等待状态之前就受到了notifyall的信号

       //那将会发生严重后果，因为调用notifyall的线程只可以调用一次notifyall，那造成等待的线程将永远等待下去

       //所以在此处让它睡一小会，让其他线程有时间进入等待状态。

       //不然会收到

      }catch(InterruptedException e){

       e.printStackTrace();

      }

      notifyAll();//通知所有在这个对象上等待的线程开始执行，在这里就是通知TestNotify主线程开始执行

    }

//   notifyAll();

  }

  public int getNum(){

    return this.num;

  }

}

package threadwait;

 

public class ThreadB extends Thread{

  private ThreadA threada;

  public ThreadB(ThreadA ta){

    this.threada = ta;

  }

  public void run(){

    System.out.println(Thread.currentThread().getName()+" is waitting.");

    synchronized(threada){

      try{

       threada.wait();

      }catch(InterruptedException e){

       e.printStackTrace();

      }

      System.out.println(Thread.currentThread().getName()+" "+this.threada.getNum());

    }

   

  }

}

package threadwait;

 

public class TestNotify{

  public static void main(String args[]){

    ThreadA threada = new ThreadA();

    new ThreadB(threada).start();

    new ThreadB(threada).start();

    new ThreadB(threada).start();

    threada.start();

  }

}

위 내용은 Java에서 스레드 대기 및 알림을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!