JAVA ThreadPool & ThreadFactory

package threadPool;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @ClassName: BasicThreadFactory
 * @Description: TODO
 * @author Zhou Shengshuai
 * @date 2014年9月22日 上午10:09:30
 *
 */
public class BasicThreadFactory implements ThreadFactory {
	private final ThreadGroup threadGroup;
	private final AtomicInteger threadNumber = new AtomicInteger(1);
	private final String threadNamePrefix;

	/**
	 * 构造函数
	 *
	 * @param threadPoolName
	 *            线程池名称
	 */
	public BasicThreadFactory(String threadPoolName) {
		SecurityManager securityManager = System.getSecurityManager();

		threadGroup = (securityManager != null) ? securityManager.getThreadGroup() : Thread.currentThread().getThreadGroup();

		threadNamePrefix = threadPoolName + "-thread-";
	}

	/**
	 * 创建线程
	 */
	@Override
	public Thread newThread(Runnable runnable) {
		Thread thread = new Thread(threadGroup, runnable, threadNamePrefix + threadNumber.getAndIncrement(), 0);

		if (thread.isDaemon()) {
			thread.setDaemon(false);
		}

		if (thread.getPriority() != Thread.MAX_PRIORITY) {
			thread.setPriority(Thread.MAX_PRIORITY);
		}

		return thread;
	}
}

package threadPool;

/**
 * @ClassName: BasicThreadTask
 * @Description: TODO
 * @author Zhou Shengshuai
 * @date 2014年9月22日 上午10:12:02
 *
 */
public class BasicThreadTask implements Runnable {

	@Override
	public void run() {
		System.out.println(Thread.currentThread().getName());
	}

}

package threadPool;

import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @ClassName: MainThreadTask
 * @Description: TODO
 * @author Zhou Shengshuai
 * @date 2014年9月22日 上午10:14:34
 *
 */
public class MainThreadTask {
	private ThreadPoolExecutor threadPoolExecutor = null;

	public void initial() {
		threadPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors(), new BasicThreadFactory("BasicThreadFactory"));
	}

	public void execute() {
		for (int index = 0; index < 10; index++) {
			threadPoolExecutor.execute(new BasicThreadTask());
		}
	}

	public void destroy() {
		threadPoolExecutor.shutdown();
	}

	/**
	 * @Title: main
	 * @Description: TODO
	 * @param args
	 * @throws
	 */
	public static void main(String[] args) {
		MainThreadTask mainThreadTask = new MainThreadTask();

		mainThreadTask.initial();
		mainThreadTask.execute();
		mainThreadTask.destroy();
	}

}