directdispatcher.java

银行项目为后台ｓｏｃｋｅｔ通信写的程序

/****************************************************************************
 * Package		: com.ecSolutions.ecAppServer.server.session.dispatcher
 * File			: DirectDispatcher.java
 * Create Date  : 2007-7-20
 * Author		: Steven Chen
 * 
 * Copyright(C) 2006 ecSolutions(shanghai) Co.,Limited.All Rights Reserved.
 *			
 ***************************************************************************/
package com.ecSolutions.ecAppServer.server.session.dispatcher;

import com.ecSolutions.ecAppServer.server.Session;
import com.ecSolutions.ecAppServer.server.util.LogThreadGroup;
import edu.emory.mathcs.backport.java.util.LinkedList;
import edu.emory.mathcs.backport.java.util.Queue;

/**
 * Direct dispatcher implementation, do not support block operation such as
 * Future.complete.
 * 
 * @author Steven Chen
 * @version $Id: DirectDispatcher.java,v 1.2 2007/07/26 03:38:57 stevenchen Exp $
 */
public class DirectDispatcher implements Dispatcher {

    private final ThreadLocal local = new ThreadLocal();

    public void block() {
        if (LogThreadGroup.CINDY_THREAD_GROUP.parentOf(Thread.currentThread()
                .getThreadGroup()))// can't block kernel thread
            throw new IllegalStateException("can't block kernel thread");
    }

    private Queue getQueue() {
        Queue queue = (Queue) local.get();
        if (queue == null) {
            queue = new LinkedList();
            local.set(queue);
        }
        return queue;
    }

    public void dispatch(Session session, Runnable event) {
        Queue queue = getQueue();
        queue.add(event); // enqueue

        if (queue.size() == 1) {
            event.run();
            queue.poll(); // dequeue current runnable
            for (Runnable task = null; (task = (Runnable) queue.peek()) != null; queue
                    .poll())
                task.run();
        }
    }
}