package com.honzh.mwq.bio.server.handler;

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

public class TimeServerHandlerPool {
	private ExecutorService service;

	/** 
	* @Title: TimeServerHandlerPool
	* @Description: 构造方法需要进行说明一下：<br>
	* <p>1.Runtime.getRuntime().availableProcessors()可以向Java虚拟机获取可用处理器的数目</p>
	* <p>2.同时你可以在cmd命令下通过echo %NUMBER_OF_PROCESSORS%获取可用的cpu可用线程数</p>
	* <p>3.我的机器是i3 3220，是一个2核心4线程的处理器，那么在不考虑资源冲突的情况下，可以支持虚拟4核的任务</p>
	* <p>4.同时查看API可以知道，对于有界队列，corepoolsize和maxpoolsize之间有一定的关系，在execute执行任务时，如果运行的线程小于core，那么始终会创建新的线程，
	* 如果运行的线程等于大于core，那么就会将请求加入队列，如果无法加入队列，则创建新的线程，如果线程数大于max，则任务将被拒绝。
	* </p>
	* 
	*/
	public TimeServerHandlerPool() {
		service = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), 100, 120L, TimeUnit.SECONDS,
				new ArrayBlockingQueue<Runnable>(1000));
	}

	public void execute(Runnable task) {
		service.execute(task);
	}
}

?这个类非常关键，注意注释中所说的内容，

另外再看server类

TimeServerHandlerPool pool = new TimeServerHandlerPool();
			Socket socket = null;
			while (true) {
				socket = server.accept();
				
				pool.execute(new TimeServerHandler(socket));
			}