事件驱动 _2

import com.mars.util.ClassMethod;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import java.util.EventListener;import java.util.EventObject;import java.util.HashSet;import java.util.Set;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;public class EventTest222 {    public static void main(String[] args) {        EventSource eventSource = new EventSource();        TestEventListener listener = new TestEventListener();        eventSource.addListener(listener);        TestEventListener2 listener2 = new TestEventListener2();        eventSource.addListener(listener2);        int count = 0;        while (true) {            if (count % 3 == 1)                eventSource.publishEvent(new TestEvent(123, "一个事件"));            else                eventSource.publishEvent(new TestEvent2(456, "一个事件"));            count++;            if (count > 10000)                break;        }    }}abstract class MarsEvent extends EventObject {    public MarsEvent(Object source) {        super(source);    }    public abstract String eventType();    public abstract String getMsg();}class Constants {    public static final String EVENT_TYPE_1 = "1";    public static final String EVENT_TYPE_2 = "2";    public static final String EVENT_TYPE_3 = "3";}/** * 事件对象 */class TestEvent extends MarsEvent {    private String msg;    /**     * Constructs a prototypical Event.     *     * @param source The object on which the Event initially occurred.     * @param msg    附加消息     * @throws IllegalArgumentException if source is null.     */    public TestEvent(Object source, String msg) {        super(source);        this.msg = msg;    }    public String getMsg() {        return "eventType = " + eventType() + " || " + this.msg;    }    @Override    public String eventType() {        return Constants.EVENT_TYPE_1;    }}class TestEvent2 extends MarsEvent {    public static final String EventType = "2";    private String msg;    /**     * Constructs a prototypical Event.     *     * @param source The object on which the Event initially occurred.     * @param msg    附加消息     * @throws IllegalArgumentException if source is null.     */    public TestEvent2(Object source, String msg) {        super(source);        this.msg = msg;    }    public String getMsg() {        return "eventType = " + eventType() + " || " + this.msg;    }    @Override    public String eventType() {        return Constants.EVENT_TYPE_2;    }}interface MarsEventListener extends EventListener {    String eventType();}/** * 事件监听者，按照 Java 规范应实现 EventListener 接口 */class TestEventListener implements MarsEventListener {    private static final Logger LOGGER = LoggerFactory.getLogger(TestEventListener.class);    public void handleEvent(MarsEvent event) {        LOGGER.info(ClassMethod.loggerInfo("TestEvent, msg is:" + event.getMsg()));    }    @Override    public String eventType() {        return Constants.EVENT_TYPE_1;    }}class TestEventListener2 implements MarsEventListener {    private static final Logger LOGGER = LoggerFactory.getLogger(TestEventListener2.class);    public void handleEvent(MarsEvent event) {        LOGGER.info(ClassMethod.loggerInfo("TestEvent222, msg222 is :" + event.getMsg()));    }    @Override    public String eventType() {        return Constants.EVENT_TYPE_2;    }}/** * 事件源 */class EventSource {    private Set<MarsEventListener> listenerSet = new HashSet<>();    public void addListener(MarsEventListener listener) {        listenerSet.add(listener);    }    public void publishEvent(MarsEvent event) {        threadPool.submit(new HandleEventThread(event));    }    public EventSource() {    }    private static final LinkedBlockingQueue<Runnable> threadQueue =            new LinkedBlockingQueue<Runnable>();    private static final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(3, 3, 60,            TimeUnit.SECONDS, threadQueue, new ThreadPoolExecutor.DiscardOldestPolicy());    class HandleEventThread implements Runnable {        private MarsEvent event;        public HandleEventThread(MarsEvent event) {            this.event = event;        }        public void run() {            MarsEventListener listener = null;            for (MarsEventListener eventListener : listenerSet) {                if (event.eventType().equals(eventListener.eventType())) {                    listener = eventListener;                    break;                }            }            if (Constants.EVENT_TYPE_1.equals(event.eventType())) {                ((TestEventListener) listener).handleEvent(event);            } else if (Constants.EVENT_TYPE_2.equals(event.eventType())) {                ((TestEventListener2) listener).handleEvent(event);            }        }    }}