Java中的wait、notify和notifyAll方法是线程之间通信的关键。wait方法用于使调用线程等待,直到另一个线程调用该对象的notify或notifyAll方法。notify方法唤醒其他线程来竞争当前线程,而notifyAll方法唤醒所有等待该对象锁的线程,以便他们可以继续竞争。
下面是一些使用wait、notify和notifyAll的示例:
示例1:基本的wait和notify方法演示
public class WaitNotifyDemo {
private Object lock = new Object();
public void waitMethod() {
synchronized (lock) {
try {
System.out.println("等待锁的线程开始等待...");
lock.wait();
System.out.println("线程已经被唤醒...");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public void notifyMethod() {
synchronized (lock) {
System.out.println("通知等待锁的线程...");
lock.notifyAll();
}
}
public static void main(String[] args) {
WaitNotifyDemo demo = new WaitNotifyDemo();
Thread t1 = new Thread(() -> {
demo.waitMethod();
});
Thread t2 = new Thread(() -> {
demo.notifyMethod();
});
t1.start();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
t2.start();
}
}
这个示例演示了两个线程之间的通信。线程t1在synchronized块中执行wait方法导致它等待。线程t2在2秒钟后调用notifyAll方法唤醒线程t1。
示例2:使用notifyAll方法
public class WaitNotifyAllDemo {
private Object lock = new Object();
private List<String> list = new ArrayList<>();
public void add() {
synchronized (lock) {
list.add("item");
// 通知所有线程,当前集合已经新增了一个元素
lock.notifyAll();
}
}
public void remove() {
synchronized (lock) {
if (list.isEmpty()) {
try {
// 如果列表为空,线程等待
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 从列表中移除第一个元素
list.remove(0);
System.out.println("移除一个元素...");
}
}
public static void main(String[] args) {
WaitNotifyAllDemo demo = new WaitNotifyAllDemo();
Thread t1 = new Thread(() -> {
for (int i = 0; i < 10; i++) {
demo.add();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 10; i++) {
demo.remove();
}
});
t1.start();
t2.start();
}
}
这个示例演示了在一个多线程环境下添加和移除元素的过程。线程t1负责添加元素,线程t2负责移除元素。如果列表为空,线程t2会等待直到线程t1添加一个元素并通知它。注意,这里使用了notifyAll方法,因为可能有多个线程等待列表中新元素的出现,notifyAll能保证通知到所有等待线程。
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Java object wait notify notifyAll代码解析 - Python技术站