264265266267268269270271272273274
logger.warn("success load data to jobTrunk."); } finally { writeLock.unlock(); } } else { logger.error("loadData error, can't get writeLock! ");
429430431432433434435436437438439
logger.warn("success load data to jobTrunk.job" + job.getJobName() + " resultPool:" + resultPool.size()); } finally { writeLock.unlock(); } } else { logger.error("loadData error, can't get writeLock! ");
755756757758759760761762763764765
WriteLock writeLock = readWriteLock.writeLock(); writeLock.lock(); try { return pool.borrowObject(); } finally { writeLock.unlock(); } } /** * {@inheritDoc}
771772773774775776777778779780781
try { pool.returnObject(obj); } catch (Exception e) { // swallowed as of Pool 2 } finally { writeLock.unlock(); } } /** * {@inheritDoc}
787788789790791792793794795796797
try { pool.invalidateObject(obj); } catch (Exception e) { // swallowed as of Pool 2 } finally { writeLock.unlock(); } } /** * {@inheritDoc}
802803804805806807808809810811812
WriteLock writeLock = readWriteLock.writeLock(); writeLock.lock(); try { pool.addObject(); } finally { writeLock.unlock(); } } /** * {@inheritDoc}
844845846847848849850851852853854
WriteLock writeLock = readWriteLock.writeLock(); writeLock.lock(); try { pool.clear(); } finally { writeLock.unlock(); } } /** * {@inheritDoc}
860861862863864865866867868869870
try { pool.close(); } catch (Exception e) { // swallowed as of Pool 2 } finally { writeLock.unlock(); } } /** * {@inheritDoc}
929930931932933934935936937938939
WriteLock writeLock = readWriteLock.writeLock(); writeLock.lock(); try { return keyedPool.borrowObject(key); } finally { writeLock.unlock(); } } /** * {@inheritDoc}
945946947948949950951952953954955
try { keyedPool.returnObject(key, obj); } catch (Exception e) { // swallowed } finally { writeLock.unlock(); } } /** * {@inheritDoc}