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

网友投稿 896 2023-04-27

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小时内删除侵权内容。

上一篇:电脑QQ浏览器打开小程序(电脑浏览器打开小程序闪退)
下一篇:Idea导入eureka源码实现过程解析
相关文章

 发表评论

暂时没有评论,来抢沙发吧~