acceptorthreadfactory.java

java NIO源代码,初学者学习java NIO技术的基础代码

package org.Arios.XFactory;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class AcceptorThreadFactory extends AxAbstractThreadFactory{

	private static final int CORE_POOL_SIZE = 2;
	private static final int MAX_POOL_SIZE = 50;
	private static final int QUEUE_CAPACITY = (CORE_POOL_SIZE + MAX_POOL_SIZE) / 2;
	private BlockingQueue<Runnable> keyQueue = new ArrayBlockingQueue<Runnable>(
			QUEUE_CAPACITY);
	private ThreadPoolExecutor pool;
	
	public AcceptorThreadFactory(String name) {
		super(name);
		pool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, 100,
				TimeUnit.MILLISECONDS, keyQueue,this);
	}
	
	@Override
	public Thread newThread(Runnable r) {
		return new Thread(r,name);
	}

	public void execute(Runnable command){
		pool.execute(command);
	}
}