okhttp中连接池实现

package com.xinyartech.mymvpdemo.okhttp.myOkhttp.pool; import android.util.Log; import java.util.Deque; import java.util.Iterator; import java.util.concurrent.*; /** * <pre> * author : QB * time : 2019/8/27 * version : v1.0.0 * desc : 连接池 * </pre> */ public class ConnectionPool { /** * 最大的等待时间，超过这个时间直接回收 */ private long keepLive; /** * 队列，存放连接池对象 */ private Deque<ConnectionHttp> queueList = new LinkedBlockingDeque<>(); /** * 判断回收线程是否启动 */ private boolean isRunning = false; /** * 闲置时间 */ private long idleTime; public ConnectionPool() { this(1, TimeUnit.SECONDS); } public ConnectionPool(long minute, TimeUnit timeUnit) { keepLive = timeUnit.toMillis(minute); } /** * 回收线程,将超时的连接对象回收掉 */ Runnable clearRunnable = new Runnable() { @Override public void run() { while (true) { long waitTime = clean(System.currentTimeMillis()); if (waitTime > 0) { //加锁，防止多次等待 synchronized (ConnectionPool.this) { try { ConnectionPool.this.wait(waitTime); } catch (InterruptedException e) { e.printStackTrace(); } } } else { //说明队列中没有等待了 System.out.println("没有连接对像>>>>"); return; } } } }; /** * 开始清除 */ private long clean(long currentTime) { Iterator<ConnectionHttp> iterator = queueList.iterator(); //下一次执行runnable循环的等待时间 long waitTime = -1; System.out.println("开始清理连接对像>>>>"); synchronized (this) { while (iterator.hasNext()) { ConnectionHttp next = iterator.next(); idleTime = currentTime - next.getLastTime(); //空闲时间大于最大允许的闲置时间，移除 if (idleTime > keepLive) { //移除连接对象 queueList.remove(next); //关闭对象的socket连接 next.closeSocket(); System.out.println("清理连接对像>>>>"); } //找到闲置时间最长的那个连接对象 if (waitTime < idleTime) { waitTime = idleTime; } } //计算清理线程需要等待的时间 if (waitTime > 0) { return keepLive - waitTime; } } return waitTime; } /** * 创建缓存队列 */ private ExecutorService executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), new ThreadFactory() { @Override public Thread newThread(Runnable r) { Thread thread = new Thread(r); thread.setDaemon(true);//设置成守护线程，生命周期跟随程序 return thread; } }); /** * 添加连接池对象 * 这里开始启动线程 */ public synchronized void addConnection(ConnectionHttp connectionHttp) { if (!isRunning) { isRunning = true; executorService.execute(clearRunnable); } queueList.add(connectionHttp); System.out.println("队列长度》》》 "+queueList.size()); } /** * 拿到连接池对象 */ public ConnectionHttp take(String host, int port) { Iterator<ConnectionHttp> iterator = queueList.iterator(); while (iterator.hasNext()) { ConnectionHttp httpConnection = iterator.next(); if (httpConnection.isConnect(host, port)) { // 移除 iterator.remove(); // 代表我们找到了 可以复用的 return httpConnection; } } return null; } }