各位童鞋 ， 对于locker  和synchronized 一起使用的时候没有想明白，请各位帮住一下。
下面是我 一个 公司写好的 DB连接池的代码.
1.getConnection() 方法中已经用了lock 为什么  getConnection() 方法中还用synchronized ，而revertConnection(Connection conn) 确没有用到

2.ConcurrentLinkedQueue<DBConn> queue 对于 queue 是不是也可以用lock 锁，好比在getConnection()方法 中 用lock 替换synchronized(queue)  
3. refreshConnection(Connection conn) 方法中
synchronized(queue){
                        queue.add(new DBConn(conn));
                        queue.notify();
                }

queue.notify();起到的是什么作用 对于对象queue 没有用到wait 呀
如果问题没有描述清楚，请call

1. public class ConnectionManager {
   
2.         private Logger logger = LoggerFactory.getLogger(ConnectionManager.class);
   
3.        
   
4.         public static final ConnectionManager instance = new ConnectionManager();
   
5.         private ReentrantLock locker = new ReentrantLock();
   
6.         private ConnectionPool pool;
   
7.         private ConnectionManager(){
   
8.                 pool = new ConnectionPool();
   
9.         }
   
10.         public static ConnectionManager getInstance(){
    
11.                 return instance;
    
12.         }
    
13.        
    
14.         public Connection getConnection(){
    
15.                 locker.lock();
    
16.                 try{
    
17.                         return pool.getConnection();
    
18.                 }finally{
    
19.                         locker.unlock();
    
20.                 }
    
21.         }
    
22.         public void revertConnection(Connection conn){
    
23.                 locker.lock();
    
24.                 try{
    
25.                         pool.revertConnection(conn);
    
26.                 }finally{
    
27.                         locker.unlock();
    
28.                        
    
29.                 }
    
30.         }

复制代码

1. package com.ourgame.clown.db;
   
2. 
   
3. import java.sql.Connection;
   
4. import java.sql.DriverManager;
   
5. import java.util.concurrent.ConcurrentLinkedQueue;
   
6. import java.util.concurrent.atomic.AtomicInteger;
   
7. 
   
8. import org.slf4j.Logger;
   
9. import org.slf4j.LoggerFactory;
   
10. 
    
11. import com.ourgame.clown.ClownData;
    
12. import com.ourgame.clown.config.ServerConfig;
    
13. 
    
14. public class ConnectionPool {
    
15.         private Logger logger = LoggerFactory.getLogger(ConnectionPool.class);
    
16.         private ConcurrentLinkedQueue<DBConn> queue;
    
17.         private AtomicInteger amount = new AtomicInteger(0);
    
18.        
    
19.         public ConnectionPool(){
    
20.                 queue = new ConcurrentLinkedQueue<DBConn>();
    
21.         }
    
22.        
    
23.         public Connection refreshConnection(Connection conn){
    
24.                 try{
    
25.                         conn.close();
    
26.                 }catch(Exception e){}
    
27.                 return createConnection();
    
28.         }
    
29.        
    
30.         public void revertConnection(Connection conn){
    
31.                 if(conn == null){
    
32.                         amount.decrementAndGet();
    
33.                         return;
    
34.                 }
    
35.                 synchronized(queue){
    
36.                         queue.add(new DBConn(conn));
    
37.                         queue.notify();
    
38.                 }
    
39.                
    
40.         }
    
41.        
    
42.         public synchronized Connection getConnection(){
    
43.                 //连接只要闲置超过一分半分钟，则抛弃不要了
    
44.                 long time = System.currentTimeMillis();
    
45.                 synchronized(queue){
    
46.                         while(queue.size()>0){
    
47.                                 DBConn sl = queue.poll();
    
48.                                 if(time - sl.activeTime>90000){
    
49.                                         try{
    
50.                                                 sl.conn.close();
    
51.                                                 logger.debug("DBManager Close a overtime connection. connection amount="+amount.decrementAndGet()+" queue size="+queue.size());
    
52.                                         }catch(Exception e){}
    
53.                                         continue;
    
54.                                 }else{
    
55.                                         logger.debug("DBManager getConnection. connection amount="+amount.get()+" queue size="+queue.size());
    
56.                                         return sl.conn;
    
57.                                 }
    
58.                         }
    
59.                 }
    
60.                 try{
    
61.                         return createConnection();
    
62.                 }catch(Exception e){
    
63.                         e.printStackTrace(System.err);
    
64.                         return null;
    
65.                 }
    
66.                
    
67.         }
    
68.        
    
69.         private synchronized Connection createConnection(){
    
70.                 Connection conn = null;
    
71.                 try{
    
72.                         ServerConfig config = ClownData.getInstance().getServerConfig();
    
73.                         Class.forName(config.getDbDriver());
    
74.                         String url = config.getDbDriverURL();
    
75.                         if(config.getDbMirror() != null && config.getDbMirror().length()>0){
    
76.                                 url += ";failover partner="+config.getDbMirror();
    
77.                         }
    
78.                         conn = DriverManager.getConnection(url,
    
79.                                         config.getDbUser(),
    
80.                                         config.getDbPass());
    
81.                 }catch(Exception e){
    
82.                         logger.debug("Fatal Error create db connection failed.");
    
83.                 }
    
84.                 amount.incrementAndGet();
    
85.                 return conn;
    
86.         }
    
87.        
    
88.         class DBConn{
    
89.                 public long activeTime;
    
90.                 public Connection conn;
    
91.                 public DBConn(Connection conn){
    
92.                         this.conn = conn;
    
93.                         this.activeTime = System.currentTimeMillis();
    
94.                 }
    
95.         }
    
96. }
    
97. 
    

复制代码

连飘的都木有， 自己飘一下， 大虾们帮忙解释一下{:soso_e141:}

你的代码，我想说注释太少，看起来很费劲的，而且代码又不是很少的情况下

神之梦 发表于 2013-8-14 00:20
你的代码，我想说注释太少，看起来很费劲的，而且代码又不是很少的情况下 ...

版主 这两个代码 可以全部复制。 是个完整的。 如果有什么需要 我会继续粘出代码。
第一步：首先看的是 想获取连接数据库 访问ConnectionManager  类中getConnection()方法 ，这个方法继续访问。ConnectionPool 类中 getConnection() 方法。
1 我不理解的是 在ConnectionManager  类中getConnection()方法里面已经加了lock 锁 ，为什么 在ConnectionPool 类中 getConnection() 方法中 还需要,synchronized 的 。
2，ConnectionPool 类中 getConnection() 方法中对queue 进行了synchronized 是不是可以换成lock

我觉得吧ConnectionManager 中的getConnection()中用不用锁都可以。