线程间的通讯

2019-03-30  本文已影响0人  迷糊小生

方法wait()的作用是使当前执行代码的线程进行等待,wait()方法是Object类的方法,该方法用来将当前线程置入“预执行队列”中,并且在wait()所在的代码行出停止执行,直到接到通知或被线程中断为止。在调用wait()之前,线程必须获得该对象的对象级别锁,即只能在同步方法或同步块中调用wait()方法。在执行wait()方法后,当前线程释放锁。在从wait()返回前,线程与其他线程竞争重新获得锁。

方法notify()也要在同步方法或同步代码块中调用。该方法用来通知那些可能等待该对象的对象锁的其他线程,如果有多个线程等待,则由线程规划器随机挑出其中一个呈wait状态的线程,对其发出通知notify,并使它等待获取该对象的对象锁。需要说明的是,在执行notify()方法后,当前线程不会马上释放该对象锁,呈wait状态的线程也并不能马上获取该对象锁,而是要等notify所在的代码块执行完毕后,当前线程才会释放锁,而呈wait状态所在的线程才可以获取该对象锁。

public class ThreadA extends Thread{

    private Object lock;
    
    public ThreadA(Object lock) {
        this.lock = lock;
    }
    
    @Override
    public void run() {
        try {
            synchronized (lock) {
                System.out.println("wait start....." + System.currentTimeMillis());
                lock.wait();
                System.out.println("wait end....." + System.currentTimeMillis());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
}
public class ThreadB extends Thread{

    private Object lock;
    
    public ThreadB(Object lock) {
        this.lock = lock;
    }
    
    @Override
    public void run() {
        synchronized (lock) {
            System.out.println("notify start....." + System.currentTimeMillis());
            lock.notify();
            System.out.println("notify end....." + System.currentTimeMillis());
        }
    }
    
}
public class ThreadTest {
    public static void main(String[] args) {
        try {
            Object lock = new Object();
            ThreadA threadA = new ThreadA(lock);
            threadA.setName("A");
            threadA.start();
            Thread.sleep(3000);
            ThreadB threadB = new ThreadB(lock);
            threadB.setName("B");
            threadB.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
image.png
上一篇下一篇

猜你喜欢

热点阅读