Object类wait及notify方法原理实例解析

Object类wait及notify方法原理实例解析

Object类中的wait和notify方法(生产者和消费者模式)　　不是通过线程调用

wait()：　　　　让正在当前对象上活动的线程进入等待状态，无期限等待，直到被唤醒为止

notify()：　　　 让正在当前对象上等待的线程唤醒

notifyAll():　　　唤醒当前对象上处于等待的所有线程

生产者和消费者模式 生产线程和消费线程达到均衡

wait方法和notify方法建立在synchronized线程同步的基础之上

wait方法：　　 释放当前对象占有的锁

notify方法：　　 通知，不会释放锁

实现生产者和消费者模式　　仓库容量为10

代码如下

import java.util.ArrayList;

public class Test_14 {

public static void maihttp://n(String[] args) {

http:// ArrayList list = new ArrayList();

Thread t1 = new Thread(new ProducerThread(list));

t1.setName("producer");

Thread t2 = new Thread(new ConsumerThread(list));

t2.setName("consumer");

t1.start();

t2.start();

}

}

//生产者线程

class ProducerThread implements Runnable{

private ArrayList arrayList;

public ProducerThread(ArrayList arrayList) {

this.arrayList = arrayList;

}

@Override

public void run() {

while (true) {

synchronized (arrayList) {

if (arrayList.size() > 9){

try {

arrayList.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

arrayList.add(new Object());

System.out.println(Thread.currentThread().getName() + "---> 生产" + "---库存" + arrayList.size());

arrayList.notify();

}

}

}

}

//消费者线程

class ConsumerThread implements Runnable{

private ArrayList arrayList;

public ConsumerThread(ArrayList arrayList) {

this.arrayList = arrayList;

}

@Override

public void run() {

while (true){

synchronized (arrayList){

if (arrayList.size() < 9){

try {

arrayList.wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

try {

http:// Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

arrayList.remove(0);

System.out.println(Thread.currentThread().getName() + "---> 消费" + "---库存" + arrayList.size());

arrayList.notify();

}

}

}

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。