事件模型 java_事件驱动模型的简单Java实现
事件驱动模型的原理不再赘述,Swing是不错的实现。别人也有不错的博文来说明原理。
本文的目的是提供一种简单的,可供参考的简短代码,用来帮助理解该模型。
Project Navigator
Event
事件通用接口:
Java代码
package org.joshua.event.events;
public interface Event {
}
Click事件:
Java代码
package org.joshua.event.events;
public class ClickEvent implements Event {
}
Double click事件:
Java代码
package org.joshua.event.events;
public class DblClickEvent implements Event {
}
Listener
事件监听器通用接口:
Java代码
package org.joshua.event.listener;
import org.joshua.event.events.Event;
public interface EventListener {
public void handleEvent(T event);
}
Click事件监听器:
Java代码
package org.joshua.event.listener;
import org.joshua.event.events.ClickEvent;
public interface ClickEventHandler extends EventListener {
}
Double Click事件监听器:
Java代码
package org.joshua.event.listener;
import org.joshua.event.events.DblClickEvent;
public interface DblClickEventHandler extends EventListener {
}
Event Source
事件源通用接口:
Java代码
package org.joshua.event.source;
import org.joshua.event.events.Event;
import org.joshua.event.listener.EventListener;
public interface EventSource {
void addEventListener(EventListener extends Event> listener);
void removeEventListener(EventListener extends Event> listener);
void notifyListeners(Event event);
}
模拟的按钮控件:
Java代码
package org.joshua.event.source;
import java.util.LinkedList;
import java.util.List;
import org.joshua.event.events.Event;
import org.joshua.event.listener.EventListener;
public class Button implements EventSource {
protected List> listeners = new LinkedList>();
@Override
public void addEventListener(EventListener extends Event> listener) {
listeners.add(listener);
}
@Override
public void removeEventListener(EventListener extends Event> listener) {
listeners.remove(listener);
}
@Override
public void notifyListeners(Event event) {
for (EventListener listener : listeners) {
try {
listener.handleEvent(event);
} catch (ClassCastException e) {
}
}
}
}
Client
Java代码
package org.joshua.event;
import org.joshua.event.events.ClickEvent;
import org.joshua.event.events.DblClickEvent;
import org.joshua.event.events.Event;
import org.joshua.event.listener.ClickEventHandler;
import org.joshua.event.listener.DblClickEventHandler;
import org.joshua.event.source.Button;
import org.junit.Before;
import org.junit.Test;
public class Client {
private Event currentEvent;
private Button button;
@Before
public void initComponent() {
button = new Button();
button.addEventListener(new ClickEventHandler() {
@Override
public void handleEvent(ClickEvent event) {
System.out.println("Button was clicked!");
}
});
button.addEventListener(new DblClickEventHandler() {
@Override
public void handleEvent(DblClickEvent event) {
System.out.println("Button was double clicked!");
}
});
}
@Test
public void testCommonEvents() {
currentEvent = new ClickEvent();
button.notifyListeners(currentEvent);
currentEvent = new DblClickEvent();
button.notifyListeners(currentEvent);
}
}
Button类中的notifyListener方法实现起来虽方便,利用了一把异常机制,但着实不推荐大家在项目中这样做。且不说性能问题,Listener的handleEvent方法里所有抛出的ClassCastException都需要重新包装。当然,我们可以使用annotation、限定类名等方式相对优雅地解决event和对应listener的mapping问题。
多线程事件处理机制
思路是用队列暂存事件,然后若干个事件分发器将事件分发给指定数量的事件处理线程处理。
Java代码
package com.joshua.test.event;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import com.joshua.test.event.event.Event;
import com.joshua.test.event.event.EventType;
import com.joshua.test.event.handler.CreateEventHandler;
public class EventManager {
private static final int EVENT_QUEUE_LENGTH = 1000;
private static final int DISPATCHER_NUM = 2;
private static final int EVENT_HANDLER_NUM = 10;
public BlockingQueue eventQueue = new LinkedBlockingQueue(EVENT_QUEUE_LENGTH);
private ExecutorService eventHandlerPool;
protected EventDispatcher createDispatcher() {
EventDispatcher dispatcher = new EventDispatcher(this.eventQueue, this.eventHandlerPool);
dispatcher.register(EventType.CREATE, CreateEventHandler.class);
return dispatcher;
}
public void init() {
eventHandlerPool = Executors.newFixedThreadPool(EVENT_HANDLER_NUM);
}
public void start() {
for (int i = 0; i
createDispatcher().start();
}
}
public void notify(Event event) {
try {
eventQueue.put(event);
} catch (InterruptedException e) {
}
}
}
Java代码
package com.joshua.test.event;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import com.joshua.test.event.event.Event;
import com.joshua.test.event.event.EventType;
import com.joshua.test.event.handler.EventHandler;
@SuppressWarnings("rawtypes")
public class EventDispatcher {
private final BlockingQueue eventQueue;
private final ExecutorService eventHandlerPool;
protected final Map> eventDispatchers = new HashMap>();
private Thread eventHandlingThread;
private volatile boolean stopped = false;
public EventDispatcher(BlockingQueue eventQueue, ExecutorService eventHandlerPool) {
this.eventQueue = eventQueue;
this.eventHandlerPool = eventHandlerPool;
System.out.println("Event dispatcher starting...");
}
Runnable createThread() {
return new Runnable() {
@Override
public void run() {
while (!stopped && !Thread.currentThread().isInterrupted()) {
Event event;
try {
event = eventQueue.take();
} catch (InterruptedException ie) {
if (!stopped) {
System.out.println("Dispatcher thread interrupted");
ie.printStackTrace();
}
return;
}
if (event != null) {
dispatch(event);
}
}
}
};
}
@SuppressWarnings("unchecked")
protected void dispatch(Event event) {
EventType type = event.getType();
try {
Class extends EventHandler> handlerClazz = eventDispatchers
.get(type);
if (handlerClazz != null) {
EventHandler handler = handlerClazz.newInstance();
handler.setEvent(event);
eventHandlerPool.submit(handler);
} else {
throw new Exception("No handler for registered for " + type);
}
} catch (Throwable t) {
System.err.println("Error in dispatcher thread");
t.printStackTrace();
System.exit(-1);
}
}
public void register(EventType eventType,
Class extends EventHandler> handler) {
Class extends EventHandler> registeredHandler = eventDispatchers
.get(eventType);
System.out.println("Registering " + eventType + " for "
+ handler);
if (registeredHandler == null) {
eventDispatchers.put(eventType, handler);
}
}
public void start() {
eventHandlingThread = new Thread(createThread());
eventHandlingThread.setName("AsyncDispatcher event handler");
eventHandlingThread.start();
System.out.println("Event dispatcher started!");
}
public void stop() {
stopped = true;
if (eventHandlingThread != null) {
eventHandlingThread.interrupt();
try {
eventHandlingThread.join();
} catch (InterruptedException ie) {
System.out.println("Interrupted Exception while stopping");
ie.printStackTrace();
}
}
}
}
转自 http://joshuasabrina.iteye.com/blog/1812722
事件模型 java_事件驱动模型的简单Java实现相关推荐
- java事件驱动模型_Spring事件驱动模型详解
事件驱动模型简介 事件驱动模型也就是我们常说的观察者,或者发布-订阅模型:理解它的几个关键点:首先是一种对象间的一对多的关系:最简单的如交通信号灯,信号灯是目标(一方),行人注视着信号灯(多方): 当 ...
- eventhandler java_事件驱动模型的简单Java实现
事件驱动模型的原理不再赘述,Swing是不错的实现.别人也有不错的博文来说明原理. 本文的目的是提供一种简单的,可供参考的简短代码,用来帮助理解该模型. Project Navigator Event ...
- 嵌入式C开发中编程模型——重点事件驱动和表驱动
嵌入式C开发中编程模型 事件驱动 消息驱动 事件驱动vs消息驱动 数据驱动 1. 表驱动法(Table-Driven) 用表驱动法来实现 Unix设计原则中的"分离原则"和&quo ...
- .net 事件委托 java_仿net事件委托的java事件模型实现(转csdn)
作为对比,我们来看看Java Swing的事件处理和委托就要复杂很多:代码如下:(您若还不是很了解Swing事件驱动的话,可以参考我的另外一篇文章:事件驱动模型实例详解(Java篇))://为btnS ...
- (六)观察者模式详解(包含观察者模式JDK的漏洞以及事件驱动模型)决了当时的问题,那时LZ接触JAVA刚几个月,比葫芦画瓢的用了观察者模式。...
本章我们讨论一个除前面的单例以及代理模式之外,一个WEB项目中有可能用到的设计模式,即观察者模式. 说起观察者模式,LZ还是非常激动的,当初这算是第一个让LZ感受到设计模式强大的家伙.当初LZ要做一个 ...
- 四国军棋引擎开发(2)简单的事件驱动模型下棋
这次在随机乱下的基础上加上了一些简单的处理,如进营.炸棋.吃子等功能,在和敌方棋子产生碰撞之后会获取敌方棋子大小的一些信息,目前采用的是事件驱动模型,当下完一步棋界面返回结果后会判断是否触发了相关事件 ...
- java 事件驱动模式_事件驱动模型实例详解(Java篇)
或许每个软件从业者都有从学习控制台应用程序到学习可视化编程的转变过程,控制台应用程序的优点在于可以方便的练习某个语言的语法和开发习惯(如.net和java),而可视化编程的学习又可以非常方便开发出各类 ...
- 灰色模型 java代码_灰色模型的简单Java实现
前几天在以前的遗留代码中发现一个问题,就是我生成的一个数据的走势曲线的预测值(用于灰色时间序列预测)总是和老代码里的不一致,具体来说就是:遗留代码里面的预测值的斜率总是为零,相比之下我生成的就比较合理 ...
- arma模型 java_时间序列分析之 ARIMA 模型的JAVA实现
最近要用ARIMA模型预测用户的数量变化,所以调研了一下ARIMA模型,最后用JAVA实现了ARIMA算法. 一.ARIMA原理 ARIMA的原理主要参考的是ARIMA原理. 二.JAVA实现 弄懂了 ...
最新文章
- MP4文件格式带数据详解
- 【转:SAP学习篇】Fiori 的开发工具
- redis 读取mysql数据类型_认识Redis与Redis的数据类型
- 一个技术管理者的苦逼【技术管理漫谈】
- 哈维玛德学院 计算机,这些美国大学名气不高,却有最顶级的工程专业
- 深层剖析鸿蒙轻内核M核的动态内存如何支持多段非连续性内存
- php mysql latin1_mysql从latin1转utf-8的经验
- hdu-2032杨辉三角
- 程序员这个职业会是另一个即将破灭的泡沫吗?
- SpringMVC深度探险(四) —— SpringMVC核心配置文件详解
- 批处理转成可执行文件的软件
- 大数据技术原理与应用(课后作业)
- 用对分法求解方程x^3-x^2-x-1=0
- 尚硅谷javaWeb书城项目第一阶段 用js实现
- shader拖尾_【OpenGL编程】拖尾、刀光、剑光、尾焰效果的开发
- 【C系列6.6】数组训练之金鱼
- linux常见桌面系统以及安装gnome远程桌面
- 【全源码及文档】基于JSP的网上订餐管理系统的设计与实现
- 三层交换机原理及配置
- mysql 找表重复数据,mysql 数据表中查找重复记录
热门文章
- PC电脑端社交应用设计灵感
- 支架预压弹性变形值计算_现浇连续梁桥支架搭设及预压施工技术控制
- 使用WindowsAPI创建txt文件
- 直接插入排序(C语言)实现
- MyBatis的总结(下)
- 延迟和带宽:时延简介、最后一英里、核心网带宽、网络边缘
- 区块链 2.0:下一个计算范式
- C/C++常量数据类型
- ppt倒计时3分钟_这些出神入化的PPT小技巧,帮你轻松告别丑PPT!花3分钟看一看吧...
- 对python的功能和扩展功能的认知_Python基础-基础认知和库了解