ConcurrentHashMap实现数据库连接的问题求助
- private ConcurrentHashMap<String,FutureTask<Connection>>connectionPool = new ConcurrentHashMap<String, FutureTask<Connection>>();
- public Connection getConnection(String key) throws Exception{
- FutureTask<Connection>connectionTask=connectionPool.get(key);
- if(connectionTask!=null){
- return connectionTask.get();
- }
- else{
- Callable<Connection> callable = new Callable<Connection>(){
- @Override
- public Connection call() throws Exception {
- // TODO Auto-generated method stub
- return createConnection();
- }
- };
- FutureTask<Connection>newTask = new FutureTask<Connection>(callable);
- connectionTask = connectionPool.putIfAbsent(key, newTask);
- if(connectionTask==null){
- connectionTask = newTask;
- connectionTask.run();
- }
- return connectionTask.get();
- }
- }
- //创建Connection
- private Connection createConnection(){
- return null;
- }
-
-
- 这是在网上看到的一段 ConcurrentHashMap实现数据库连接的代码，发现有个问题：
- 就是在线程A、B同时执行获取数据库连接的方法时，如果线程A执行完17行，返回null，说明它是首个存入该key的线程，但是不幸的是A线程因为某些原因此时突然挂掉了。线程B执行到17行时发现此时已经有线程存入了key，connectionTask不为null，则直接跳到22行去get数据库连接，但是因为线程A没有执行完创建连接，所以线程B就一直阻塞在get方法上。请各位大神看看是不是存在这个问题，如果存在，如何更好的解决？
美团公司氛围 2510人发布
