伪异步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分钟，接着假如以后的请求都不能再加入到阻塞队列后，新的请求将会被拒绝，那么这就像等于系统崩溃了。