等待超时模式

就是超过时间后执行我设定的逻辑，通过定义一个等待持续时间T，超时时间就是now＋T，如果未来时间比now+T晚，就是超时了，采用判断语句来进行判断。

数据库连接池

模拟从连接池中获 取、使用和释放连接的过程，而客户端获取连接的过程被设定为等待超时的模式，也就是在 1000毫秒内如果无法获取到可用连接，将会返回给客户端一个null。设定连接池的大小为10 个，然后通过调节客户端的线程数来模拟无法获取连接的场景。

连接池的定义

通过构造函数初始化连接的最大上限，通过一个双向队列 、来维护连接，调用方需要先调用fetchConnection(long)方法来指定在多少毫秒内超时获取连接， 当连接使用完成后，需要调用releaseConnection(Connection)方法将连接放回线程池

 代码

package test730;import java.sql.Connection;
import java.util.LinkedList;
/*
线程池的实现*/
public class ConnectionPool {private LinkedList<Connection> pool = new LinkedList<Connection>();//线程初始化构造函数，确定线程池的大小public ConnectionPool(int initialSize){if (initialSize>0){for (int i = 0; i < initialSize; i++) {pool.addLast(ConnectionDriver.createConnection());}}}//释放连接方法public void releaseCoonnection(Connection connection){if (connection != null){synchronized (pool){//释放后归还，并唤醒其他需要建立连接的线程pool.addLast(connection);pool.notifyAll();}}}//在mills内无法获取到链接，将会返回nullpublic  Connection fetchConnection(long mills) throws InterruptedException{synchronized (pool){// 如果超时时间小于等于0，表示不设定超时if (mills<=0){// 当连接池为空时，线程将会在此处等待直到连接池中有可用的连接while (pool.isEmpty()){pool.wait();}// 从连接池中移除并返回第一个连接return pool.removeFirst();}else {// 设置未来的时间点，用于计算剩余等待时间long future = System.currentTimeMillis() + mills;long remaining = mills;// 当连接池为空且剩余等待时间大于0时，线程将会等待while ( pool.isEmpty() && remaining>0){// 线程等待指定的时间（remaining），直到有连接可用pool.wait(remaining);// 更新剩余等待时间remaining = future - System.currentTimeMillis();}// 从连接池中移除并返回第一个连接（如果连接池中有连接的话）Connection result = null;if (!pool.isEmpty()){result = pool.removeFirst();}return result;}}}
}

package test730;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.util.concurrent.TimeUnit;public class ConnectionDriver {// 内部类 ConnectionHandler 实现 InvocationHandler 接口static class  ConnectionHandler implements InvocationHandler{// 重写 invoke 方法，用于处理方法调用public  Object invoke(Object proxy, Method method,Object[] args)throws Throwable{// 如果调用的方法是 "commit"if (method.getName().equals("commit")){// 让当前线程暂停 100 毫秒TimeUnit.MILLISECONDS.sleep(100);}return  null;}}// 创建连接的静态方法public static final Connection createConnection(){// 使用 Proxy.newProxyInstance 创建一个动态代理对象return (Connection) Proxy.newProxyInstance(ConnectionDriver.class.getClassLoader(),new Class<?>[] {Connection.class},new ConnectionHandler());}
}