axacceptormanager.java

来自「java NIO源代码,初学者学习java NIO技术的基础代码」· Java 代码 · 共 53 行

package org.Arios.XServer;

import java.nio.channels.SelectionKey;
import java.util.concurrent.ConcurrentLinkedQueue;

import org.Arios.XFactory.AcceptorThreadFactory;
import org.Arios.XFactory.AxAbstractThreadFactory;

public class AxAcceptorManager {
	private static final int SELECTOR_MAX_MUN = 50;
	
	private ConcurrentLinkedQueue<AxAbstractAccepter> acceptorFreeQueue = new ConcurrentLinkedQueue<AxAbstractAccepter>();
	private static AxAcceptorManager instance = new AxAcceptorManager();
	private AxAbstractAccepter acceptor;
	private AxAbstractThreadFactory factory;

	private AxAcceptorManager() {
		acceptor = new AxAcceptor(SELECTOR_MAX_MUN);
		factory = new AcceptorThreadFactory("AcceptorThread");
	}

	public static AxAcceptorManager getInstance() {
		return instance;
	}

	public void update() {
		this.acceptor = getFreeOne();
	}

	public void start(SelectionKey key) {
		if (!acceptor.isAlive())
			factory.execute(acceptor);
		this.acceptor.register(key);
	}

	public void add(AxAbstractAccepter acceptor) {
		if (!acceptorFreeQueue.contains(acceptor))
			acceptorFreeQueue.offer(acceptor);
	}

	public void remove(AxAbstractAccepter acceptor) {
		if (acceptorFreeQueue.contains(acceptor))
			acceptorFreeQueue.remove(acceptor);
	}

	public AxAbstractAccepter getFreeOne() {
		if (acceptorFreeQueue.size() != 0)
			return acceptorFreeQueue.poll();
		else
			return new AxAcceptor(SELECTOR_MAX_MUN);
	}
}