Multithreaded Wait, Notify, and notifyAll

package test1; import java.util.LinkedList; Public class T13 {public static void main(String[] args) {final MessageQueue = new MessageQueue(3); System.out.println("***************task begin***************"); // Create producer Thread and start new Thread(() -> {while (true) { mq.set(new Message()); }},"producer").start(); // Create consumer Thread and start new Thread(() -> {while (true) { mq.get(); }},"consumer").start(); }} /** * MessageQueue {/** * private final int Max; /* * lock * */ private final byte[] Lock = new byte[1]; /** * final LinkedList<Message> messageQueue = new LinkedList<>(); /** * The constructor default queue size is 10 */ publicMessageQueue() { max = 10; } public MessageQueue(int x) {Max = x; } public voidset(Message Message) {synchronized (lock) {// If the number of synchronized queues exceeds that of synchronized (lock) {// If the number of synchronized queues exceeds that of synchronized (lock)if (messageQueue.size() > max) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is full ,waiting..."); lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); Println (thread.currentThread ().getName() +)" : add a message");
messageQueue.addLast(message);
lock.notify();
}
}
public void get() {synchronized (lock) {// if the queue is empty, the message cannot be obtainedif (messageQueue.isEmpty()) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is empty ,waiting..."); lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); Println (thread.currentThread ().getName() +);} // If the queue is not empty, the message is read and the waiting Thread on the lock is notified" : get a message"); messageQueue.removeFirst(); lock.notify(); } /** * The Message stored in the Message queue */ class Message {}Copy the code

public void set(Message Message) {synchronized (lock) {// If the number of synchronized queues exceeds that of synchronized (lock) {// If the number of synchronized queues exceeds that of synchronized (lock)if (messageQueue.size() > max) {
try {
System.out.println(Thread.currentThread().getName() + " : queue is full ,waiting..."); lock.wait(); } catch (InterruptedException e) { e.printStackTrace(); Println (thread.currentThread ().getName() +)" : add a message"); messageQueue.addLast(message); lock.notify(); }}Copy the code