java——利用生产者消费者模式思想实现简易版handler机制

参考教程：http://www.sohu.com/a/237792762_659256

首先介绍每一个类：

1.Message：

　　这个类的作用是存储一个生产者生产出来的具体的消息，就类似链表队列中的一个节点，自行定义需要存储的内容。

　　code：消息要执行的具体动作代码

　　msg：消息内容

　　target：用来关联hadler,根本目的时为了使这几个类共享一个MessageQueue，这个很重要

2.MessageQueue：

　　这个类就是生产者和消费者线程需要共享的一个存储消息的队列，生产者将消息放入这个队列，消费者取出消息并处理。

　　内部实现是用了BlockingQueue，这个队列特别的地方就是出队和入队的时候是阻塞的，也就是说当队列中没有元素的时候出队这个动作会引起线程阻塞，直到有元素入队；同理入队也会因为队列满而引起线程阻塞，直到有元素出队。

　　这个类中定义了两个方法：next和enqueueMessage分别对应出对和入队。　　

　　需要考虑的就是如何将生产者和消费者多线程共享这个队列？

　　吃口饭再写，好饿

原文地址：https://www.cnblogs.com/gaoquanquan/p/9936688.html

时间： 2024-10-10 02:11:28

java——利用生产者消费者模式思想实现简易版handler机制的相关文章

关于java中生产者消费者模式的理解

在说生产者消费者模式之前,我觉得有必要理解一下 Obj.wait(),与Obj.notify()方法.wait()方法是指在持有对象锁的线程调用此方法时,会释放对象锁,同时休眠本线程.notify()方法是持有相同的对象锁来唤醒休眠的线程,使其具有抢占cpu的资格.可以理解同步方法,同步方法的对象锁就是谁调用这个方法,这个对象就是对象锁. 根据李兴华老师的视频讲解,建立一个生产者类,一个消费者类,还有一个Info类,贴上代码: 1.生产者类 package com.company; /** *

java多线程生产者消费者模式

package de.bvb; /** * 生产者消费者模式 * 通过 wait() 和 notify() 通信方法实现 * */ public class Test1 { public static void main(String[] args) { Godown godown = new Godown(50); for (int i = 0; i < 5; i++) { new ProducerThread(i * 10, godown).start(); new ConsumerThre

java 多线程-生产者消费者模式-管程法

生产者消费者模式管程法通过容器中介,将数据放入和取出 wait()导致当前线程等待,直到另一个线程调用该对象的notify()或notyfyAll()方法notify()唤醒正在等待对象监视器的单个线程,notifyAll()唤醒正在等待对象监视器的所有线程 public class tuble { public static void main(String[]args) { SynContainer container=new SynContainer(); new Productor(co

Java多线程-生产者/消费者模式实现

单生产者与单消费者示例: public class ProduceConsume { public static void main(String[] args) { String lock = new String(""); Produce produce = new Produce(lock); Consume consume = new Consume(lock); new Thread(() -> { while (true) { produce.setValue();

JAVA线程-生产者消费者模式

package cn.tt; public class ProducerConsumer { public static void main(String[] args) throws InterruptedException { SyncStack ss = new SyncStack(); Producer p = new Producer(ss); consumer c = new consumer(ss); new Thread(p).start(); Thread.sleep(2000

Java 并发编程（四）阻塞队列和生产者-消费者模式

阻塞队列阻塞队列提供了可阻塞的 put 和 take 方法,以及支持定时的 offer 和 poll 方法.如果队列已经满了,那么put方法将阻塞直到有空间可以用:如果队列为空,那么take方法将一直阻塞直到有元素可用.队列可以使有界的,也可以是无界的,无界队列永远都不会充满,因此无界队列上的put方法永远不会阻塞.一种常见的阻塞生产者-消费者模式就是线程池与工作队列的组合,在 Executor 任务执行框架中就体现了这种模式. 意义:该模式能简化开发过程,因为他消除了生产者和消费者类之间的代

设计模式—生产者消费者模式

生产者消费者模式是指生产者和消费者通过一个缓冲区(一般是一个队列)的进行通讯.生产者生产完数据之后不用等待消费者处理.直接放到缓冲区,消费者不找生产者要数据,而是直接从缓冲区里取,这样既能够保持生产者和消费者的并发处理,也能够平衡生产者和消费者的处理能力. 这样做有下面优点: ◇ 减少生产者和消费者之间的耦合性假设生产者和消费者各自是两个类.假设让生产者直接调用消费者的某个方法,那么生产者对于消费者就会产生依赖(也就是耦合).将来假设消费者的代码发生变化,可能会影响到生产者.而假设两者都依赖于

java 多线程 22 ：生产者/消费者模式进阶利用await()/signal()实现

java多线程15 :wait()和notify() 的生产者/消费者模式在这一章已经实现了 wait/notify 生产消费模型利用await()/signal()实现生产者和消费者模型一样,先定义一个缓冲区: public class ValueObject { public static String value = ""; } 换种写法,生产和消费方法放在一个类里面: public class ThreadDomain41 extends ReentrantLock {

Java线程同步与死锁、生产者消费者模式以及任务调度等

一.Thread类基本信息方法 package Threadinfo; public class MyThread implements Runnable{ private boolean flag = true; private int num = 0; @Override public void run() { while(flag) { System.out.println(Thread.currentThread().getName()+"-->"+num++); } }