伪异步IO

前言：同步阻塞IO会有很大的性能问题，那么使用线程池控制呢，就有了伪异步IO，通过线程池对消息队列和最大线程数进行控制，例子见下

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));
			}

 通过线程池管理请求任务。

总结：伪异步IO有效的解决了资源宕机的问题，但是依然有如下问题存在，输入输出流依然是阻塞的，假如server返回信息阻塞了1分钟，那么对应的client在获取资源的时候也会在读取流中阻塞1分钟，接着假如以后的请求都不能再加入到阻塞队列后，新的请求将会被拒绝，那么这就像等于系统崩溃了。