abstracteventmanager.java.svn-base

一个JAVA程序员的游戏

/*
 * AbstractEventManager.java
 *
 * Created on 7. Januar 2007, 17:32
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package kanjitori.event;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

/**
 *
 * @author Pirx
 */
public abstract class AbstractEventManager<T> implements EventManager<T> {
    
    private List <Listener<T>> list = new ArrayList<Listener<T>>();
    private boolean async = false;
    
    private static Executor executor = Executors.newFixedThreadPool(5);
    
    AbstractEventManager() {
        this(false);
    }
    
    AbstractEventManager(boolean async) {
        this.async = async;
    }
    
    public void register(Listener<T> listener) {
        if (! list.contains(listener)) {
           list.add(listener);
        }
    }

    public void unregister(Listener<T> listener) {
        list.remove(listener);
    }

    public void unregisterAll() {
        list.clear();
    }

    public void fireEvent(T message) {
        if (async) {
            fireEventAsync(message);
        } else {
            fireEventSync(message);
        }
    }
    
    private void fireEventSync(T message) {
        for (Listener<T> listener : list) {
            listener.notify(message);
        }
    }

    private void fireEventAsync(T message) {
        for (Listener<T> listener : list) {
            executor.execute(new Notifier<T>(listener, message));
        }
    }
    
    private static class Notifier<T> implements Runnable {
        private Listener<T> listener;
        private T message;
        
        public Notifier(Listener<T> listener, T message) {
            this.listener = listener;
            this.message = message;
        }
        
        public void run() {
            listener.notify(message);
        }
    }
    
}