伪异步IO

布满荆棘的人生 2021-06-24 16:09 376阅读 0赞

前言：同步阻塞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: 构造方法需要进行说明一下： 
 	* 1.Runtime.getRuntime().availableProcessors()可以向Java虚拟机获取可用处理器的数目
 	* 2.同时你可以在cmd命令下通过echo %NUMBER_OF_PROCESSORS%获取可用的cpu可用线程数
 	* 3.我的机器是i3 3220，是一个2核心4线程的处理器，那么在不考虑资源冲突的情况下，可以支持虚拟4核的任务
 	* 4.同时查看API可以知道，对于有界队列，corepoolsize和maxpoolsize之间有一定的关系，在execute执行任务时，如果运行的线程小于core，那么始终会创建新的线程，
 	* 如果运行的线程等于大于core，那么就会将请求加入队列，如果无法加入队列，则创建新的线程，如果线程数大于max，则任务将被拒绝。
 	* 
 	* 
 	*/
 	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分钟，接着假如以后的请求都不能再加入到阻塞队列后，新的请求将会被拒绝，那么这就像等于系统崩溃了。