Метод wait() класса Object в Java
Класс Object в JavaМетод wait() класса Object заставляет текущий поток перейти в состояние ожидания. Пока другой поток не вызовет у этого объекта методnotify()или методnotifyAll().。
Текущий поток должен быть владельцем монитора этого объекта, иначе будет выброшено исключениеIllegalMonitorStateException.
Если текущий поток будет прерван любым потоком до или во время ожидания, будет выброшено исключениеInterruptedException.
Синтаксис
public final void wait()
Parameters
Отсутствует 。
Возвращаемое значение
Нет возвращаемого значения.
Пример
В следующем примере демонстрируется использование метода wait():
Пример
import java.util.Collections;
import java.util.LinkedList;
import java.util.List;
public class ExampleTest extends Object {
private List synchedList;
public ExampleTest() {
//Создать синхронизированный список
synchedList = Collections.synchronizedList(new LinkedList());
}
//Удалить элемент из списка
public String removeElement() throws InterruptedException {
synchronized (synchedList) {
//Подождать, если список пуст
while (synchedList.isEmpty()) {
System.out.println("Список пуст...");
synchedList.wait();
System.out.println("Ожидание...");
}
String element = (String) synchedList.remove(0);
return element;
}
}
//Добавить элемент в список
public void addElement(String element) {
System.out.println("Открытие...");
synchronized (synchedList) {
//Добавить элемент и уведомить, что элемент существует
synchedList.add(element);
System.out.println("Новый элемент:'" + element + "'");
synchedList.notifyAll();
System.out.println("notifyAll вызван!");
}
System.out.println("Закрытие...");
}
public static void main(String[] args) {
final ExampleTest demo = new ExampleTest();
Runnable runA = new Runnable() {
public void run() {
try {
String item = demo.removeElement();
System.out.println("" + item);
} catch (InterruptedException ix) {
System.out.println("Исключение прерывания!");
} catch (Exception x) {
System.out.println("Исключение выброшено.");
}
}
};
Runnable runB = new Runnable() {
//Выполните операцию добавления элемента и запустите цикл
public void run() {
demo.addElement("Привет!");
}
};
try {
Thread threadA1 = new Thread(runA, "Google");
threadA1.start();
Thread.sleep(500);
Thread threadA2 = new Thread(runA, "Example");
threadA2.start();
Thread.sleep(500);
Thread threadB = new Thread(runB, "Taobao");
threadB.start();
Thread.sleep(1000);
threadA1.interrupt();
threadA2.interrupt();
} catch (InterruptedException x) {
}
}
}
Вывод вышеприведённой программы:
List is empty... List is empty... Opening... New Element:'Hello!' notifyAll called! Closing... Waiting... Waiting... List is empty... Hello! Interrupted Exception!
Другие расширения