一、notify()的定义和作用
Java中的notify()是Object类中的一个方法,它的作用是用于唤醒正在等待该对象锁的线程中的一个线程。当一个线程调用了对象的wait()方法后,它就会进入对象的等待池中,直到其他的线程调用了对象的notify()方法或notifyAll()方法来唤醒它。如果多个线程在同一个对象上等待,那么调用notify()方法只会唤醒其中的一个线程,并无法指定唤醒哪一个线程。以下是一段简单的代码示例,演示了如何使用wait()和notify()方法:
public class WaitAndNotifyExample{ public static void main(String[] args){ Message message = new Message("important message"); Thread waiterThread = new Thread(new Waiter(message)); Thread notifierThread = new Thread(new Notifier(message)); waiterThread.start(); notifierThread.start(); } } class Message { private String value; public Message(String value) { this.value = value; } public String getValue() { return value; } public void setValue(String value) { this.value = value; } } class Waiter implements Runnable { private Message message; public Waiter(Message message) { this.message = message; } @Override public void run() { synchronized (message) { try { System.out.println("waiter thread is waiting"); message.wait(); System.out.println("waiter thread got notified"); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("waiter thread got the message: " + message.getValue()); } } } class Notifier implements Runnable { private Message message; public Notifier(Message message) { this.message = message; } @Override public void run() { synchronized (message) { System.out.println("notifier thread is running"); message.setValue("new important message"); message.notify(); System.out.println("notifier thread has notified the waiter thread"); } } }在上述代码中,Waiter类和Notifier类分别实现了Runnable接口。Waiter类会在synchronized块中调用message的wait()方法,将该线程放到对象的等待池中。而Notifier类则在synchronized块中调用了message的notify()方法,唤醒了在对象的等待池中的一个线程(此处唤醒了Waiter线程),并且将message的值更新为“new important message”。
二、notify()的注意事项和使用场景
虽然notify()方法在多线程编程中有一定的作用,但使用它也可能在一些情况下不是很安全,因此在使用时需要注意以下几点:1. 线程的唤醒方式是随机的。这意味着调用notify()方法时不能保证哪个线程会被唤醒。
2. 如果多个线程在同一个对象上等待,那么调用notify()方法只会唤醒其中的一个线程,因此能否正常工作完全取决于你想执行的代码与哪个线程被唤醒有关。
3. 调用notify()方法不会立即释放对象锁,所以在调用这个方法之前,确保释放了所有占用的资源。
notify()方法的使用场景非常丰富,以下为一些常见场景的示例:
1. 一个生产者线程和一个消费者线程之间的通信。
2. 多个线程执行某段代码,其中一个线程需要等待其他线程的结果,然后才能执行。
3. 多个线程同时运行,但是这些线程只能在特定的条件下运行,此时可以使用wait()和notify()来实现这个条件。
三、notify()的替代方法
虽然notify()方法可以在适当的情况下实现线程之间的通信,但在某些情况下,使用替代方法更加安全。以下是一些常见的替代方法:1. 使用ReentrantLock和Condition。这个方法可以通过一个Lock对象和多个Condition对象来避免使用wait()和notify()方法,因为它允许你显式地唤醒特定的线程。
2. 使用CountDownLatch和CyclicBarrier。这两个类可以帮助多个线程协调它们之间的执行,这些线程可以在等待特定的条件后继续执行。
3. 使用Future和Callable。这个方法可以在未来的某个时间点获取异步结果。