等待/通知机制在我们生活中很常见，一个形象的例子就是厨师和服务员之间就存在等待/通知机制。
在实际应使用多线程时，线程间的角色并不一完全一样的，有的线程负责生产数据，有的线程负责消费数据。所在就会有一种情况，就是： 生产者生产数据太快，消费者消费能力跟...
timer.start(); } 5）上述代码确实可以处理任务的执行问题，但是一直使用while和if判断会消耗大量的CPU资源，所以选择使用休眠等待时间，有两个选择sleep 和 wait-notify...使用sleep会影响任务的录入，故选择wait-notify: 6）那什么时候使用notify唤醒呢？...queue.put(timerTake); synchronized (object){ object.notify(); } } 7）队列为空时，采取wait-notify
优点: 不引入其他服务依赖，wait-notify机制，不做polling，不会浪费cpu。 缺点: 数据保存在JVM内存中，当应用重启会造成数据丢失，或者数据量大时造成DelayQueue过大。...总结 我们考察了现有的延迟队列实现，基于有赞队列的实现方案—使用redis zset作为队列存储结构，同时结合了java DelayQueue的wait-notify方式，重新实现了一套延迟队列。...image.png 技术亮点 1、使用jdk的delayQueue实现原理，放弃polling方式，采用wait-notify方式获取redis zset中保存的元素，更高效。
（三）wait-notify 为了线程能按照规定的顺序执行，使用wait-notify。这两个都是Object提供的方法。
这里使用 wait-notify 和 阻塞队列(ArrayBlockingQueue)实现。...//wait-notify实现 private static void produceCustom() { Queue queue = new LinkedList
这是生产者消费者模型最重要的作用 （2）解耦，这是生产者消费者模型附带的作用，解耦意味着生产者和消费者之间的联系少，联系越少越可以独自发展而不需要收到相互的制约 26.写一个生产者-消费者队列 可以通过阻塞队列实现,也可以通过wait-notify...new Thread(p).start(); new Thread(c1).start(); new Thread(c2).start(); } } 使用wait-notify
是指任务的最多数目 对于BlockingQueue,offer 和 poll 是不带阻塞功能的（因为BlockingQueue 继承 Queue），put 和 take 带阻塞功能的，这里的阻塞功能是使用wait-notify
本节代码GitHub：https://github.com/lgsxiaosen/notes-code/tree/master/wait-notify
12、用 wait-notify 写一段代码来解决生产者-消费者问题？ 13、用 Java 写一个线程安全的单例模式（Singleton）？...12、用 wait-notify 写一段代码来解决生产者-消费者问题？ 只要记住在同步块中调用 wait() 和 notify()方 法 ，如果阻塞，通过循环来测试等待条件。
，而不会发生线程不安全 协作：通过对象的wait和notify方法实现，比如一个读的线程从缓冲区读数据，另一个线程负责往缓冲区写数据，如果缓冲区没有数据，则读线程阻塞，有数据时，读线程就要开始消费 wait-notify
实现生产者消费者模型有两种方式： 采用 wait—notify 方式实现生产者消费者模型（注意这里需要加同步锁 synchronized） 采用 阻塞队列 方式实现生产者消费者模式 ---- 3. wait-notify
2.3、ReentrantLock适用场景 某个线程在等待一个锁的控制权的这段时间需要中断 需要分开处理一些wait-notify，ReentrantLock里面的Condition应用，能够控制notify
在layering-cache里面，我们使用的是LockSupport.parkNanos方法，它会释放cpu资源, 因为我们使用的是redis分布式锁，所以也不能使用wait-notify机制。
wait-notify 机制 当synchronized方法中的wait方法被调用时，当前线程将被中断运行，并且放弃该对象的锁。 一旦线程调用了wait方法，它便进入该对象的等待列表。
可以借助 JDK Timer 类中的思想，通过 wait-notify 来节省 CPU 资源。
因为第一个方法问题比较多，所以这里借鉴了Timer中的一些思想，通过wait-notify可以达到一个比较好的延时效果，并且资源也不会浪费，第一次的时候还是获取ZSET中最小的时间，然后wait(执行时间
2.1.1 wait-notify 基于线程的wait、notify（notifyAll）方法实现 二者都是Object类的方法，使用这套方法时必须获得同步锁synchronized。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
