最近在写的数据迁移工具完成的差不多了，今天将连接池换成C3P0，发现一个问题，就是配置了多个数据源的C3P0在同时获取不同数据源的Connection时会发生死锁。 1.运行如下的代码，用JProfiler测试，会发现死锁的情况： 代码： package com.highgo.test.c3p0dea
最近在写的数据迁移工具完成的差不多了，今天将连接池换成C3P0，发现一个问题，就是配置了多个数据源的C3P0在同时获取不同数据源的Connection时会发生死锁。
1.运行如下的代码，用JProfiler测试，会发现死锁的情况：
代码：
package com.highgo.test.c3p0deadlock;
import java.sql.SQLException;
import com.mchange.v2.c3p0.ComboPooledDataSource;
//加锁source个postgre的ComboPooledDataSource的getConnection用一个锁
public class Test {
public static void main(String[] args) throws InterruptedException {
ComboPooledDataSource source = new ComboPooledDataSource("source");
ComboPooledDataSource source2 = new ComboPooledDataSource("source");
ComboPooledDataSource postgres = new ComboPooledDataSource("postgres");
ComboPooledDataSource postgres2 = new ComboPooledDataSource("postgres");
new Thread(new SourceGetConn(source), "source").start();
// new Thread(new SourceGetConn(source2), "source2").start();
// Thread.sleep(1000);
new Thread(new DestGetConn(postgres), "postgres").start();
// new Thread(new DestGetConn(postgres2), "postgres2").start();
}
}
class SourceGetConn implements Runnable {
private ComboPooledDataSource source = null;
public SourceGetConn(ComboPooledDataSource source) {
this.source = source;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
source.getConnection();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
class DestGetConn implements Runnable {
private ComboPooledDataSource postgres = null;
public DestGetConn(ComboPooledDataSource source) {
this.postgres = source;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
postgres.getConnection();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
死锁情况：
可以看到source和postgre两个进程都被一个没有记录的对象锁住了。
2.将上边的代码的Thread.sleep注释去掉，在运行，是不会有死锁问题的，于是查看C3P0的源代码，ComboPooledDataSource@getConnection是继承自AbstractPoolBackedDataSource#getConnection，代码如下：
public Connection getConnection() throws SQLException
{
PooledConnection pc = getPoolManager().getPool().checkoutPooledConnection();
return pc.getConnection();
}
public Connection getConnection(String username, String password) throws SQLException
{
PooledConnection pc = getPoolManager().getPool(username, password).checkoutPooledConnection();
return pc.getConnection();
}
先看这个PoolManager，AbstractPoolBackedDataSource#getPoolManager方法的实现如下，是线程安全的
private synchronized C3P0PooledConnectionPoolManager getPoolManager() throws SQLException
{
if (poolManager == null)
{
ConnectionPoolDataSource cpds = assertCpds();
poolManager = new C3P0PooledConnectionPoolManager(cpds, null, null, this.getNumHelperThreads(), this.getIdentityToken(), this.getDataSourceName());
if (logger.isLoggable(MLevel.INFO))
logger.info("Initializing c3p0 pool... " + this.toString( true ) /* + "; using pool manager: " + poolManager */);
}
return poolManager;
}
从上边的代码也可以看出，一个DataSource实例，只保持一个PoolManager的引用。再接着看getPool方法，也是线程安全的；
public synchronized C3P0PooledConnectionPool getPool(String username, String password, boolean create) throws SQLException
{
if (create)
return getPool( username, password );
else
{
DbAuth checkAuth = new DbAuth( username, password );
C3P0PooledConnectionPool out = (C3P0PooledConnectionPool) authsToPools.get(checkAuth);
if (out == null)
throw new SQLException("No pool has been initialized for databse user '" + username + "' with the specified password.");
else
return out;
}
}
再看C3P0PooledConnectionPool#checkoutPooledConnection（）；
public PooledConnection checkoutPooledConnection() throws SQLException
{
//System.err.println(this + " -- CHECKOUT");
try
{
PooledConnection pc = (PooledConnection) this.checkoutAndMarkConnectionInUse();
pc.addConnectionEventListener( cl );
return pc;
}
catch (TimeoutException e)
{ throw SqlUtils.toSQLException("An attempt by a client to checkout a Connection has timed out.", e); }
catch (CannotAcquireResourceException e)
{ throw SqlUtils.toSQLException("Connections could not be acquired from the underlying database!", "08001", e); }
catch (Exception e)
{ throw SqlUtils.toSQLException(e); }
}
返回一个C3P0PooledConnection 实例；C3P0PooledConnection 这个类里的方法都是线程安全的。ComboPooledDataSource@getConnection的最后一站就是C3P0PooledConnection#getConnection；如下：
public synchronized Connection getConnection()
throws SQLException
{
if ( exposedProxy != null)
{
//DEBUG
//System.err.println("[DOUBLE_GET_TESTER] -- double getting a Connection from " + this );
//new Exception("[DOUBLE_GET_TESTER] -- Double-Get Stack Trace").printStackTrace();
//origGet.printStackTrace();
// System.err.println("c3p0 -- Uh oh... getConnection() was called on a PooledConnection when " +
// "it had already provided a client with a Connection that has not yet been " +
// "closed. This probably indicates a bug in the connection pool!!!");
logger.warning("c3p0 -- Uh oh... getConnection() was called on a PooledConnection when " +
"it had already provided a client with a Connection that has not yet been " +
"closed. This probably indicates a bug in the connection pool!!!");
return exposedProxy;
}
else
{ return getCreateNewConnection(); }
}
从上边的源码分析可以看出，一个ComboPooledDataSource实例的ComboPooledDataSource@getConnection是线程安全的，可以放心调用；可以测试一下，将最开始的代码稍微修改下，如下：
package com.highgo.test.c3p0deadlock;
import java.sql.SQLException;
import com.mchange.v2.c3p0.ComboPooledDataSource;
//加锁source个postgre的ComboPooledDataSource的getConnection用一个锁
public class Test {
public static void main(String[] args) throws InterruptedException {
ComboPooledDataSource source = new ComboPooledDataSource("source");
// ComboPooledDataSource source2 = new ComboPooledDataSource("source");
ComboPooledDataSource postgres = new ComboPooledDataSource("postgres");
// ComboPooledDataSource postgres2 = new ComboPooledDataSource("postgres");
new Thread(new SourceGetConn(source), "source").start();
new Thread(new SourceGetConn(source), "source2").start();
// Thread.sleep(1000);
// new Thread(new DestGetConn(postgres), "postgres").start();
// new Thread(new DestGetConn(postgres2), "postgres2").start();
}
}
class SourceGetConn implements Runnable {
private ComboPooledDataSource source = null;
public SourceGetConn(ComboPooledDataSource source) {
this.source = source;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
source.getConnection();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
class DestGetConn implements Runnable {
private ComboPooledDataSource postgres = null;
public DestGetConn(ComboPooledDataSource source) {
this.postgres = source;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
postgres.getConnection();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
将一个ComboPooledDataSource实例，传给两个线程分别getConnection，getConnection的过程没有加锁的情况下是可以运行的，完全没有问题。3.经过测试发现同一个数据源的两个ComboPooledDataSource实例，getConnection方法不加锁的情况下，也是没有问题的。
稍微总结一下：
C3P0在一个ComboPooledDataSource实例的getConnection方法是线程安全的
C3P0在一个数据源的多个ComboPooledDataSource实例的getConnection方法也是线程安全的
C3P0在多个数据源的多个ComboPooledDataSource不同时调用getConnection的情况下，不会发生死锁（基于概率，若干时间之后，肯定会发生死锁）
C3P0在多个数据源的多个ComboPooledDataSource实例的getConnection方法同时（相邻的两行代码）调用时，会发生死锁现象，如1中所述
4.总结：
属于不同数据源的多个ComboPooledDataSource实例的getConnection方法调用要互斥
测试代码如下：
package com.highgo.test.c3p0deadlock;
import java.sql.SQLException;
import java.util.concurrent.locks.ReentrantLock;
import com.mchange.v2.c3p0.ComboPooledDataSource;
//加锁source个postgre的ComboPooledDataSource的getConnection用一个锁
public class Test2 {
public static void main(String[] args) throws InterruptedException {
ComboPooledDataSource source = new ComboPooledDataSource("source");
ComboPooledDataSource source2 = new ComboPooledDataSource("source");
ComboPooledDataSource postgres = new ComboPooledDataSource("postgres");
ComboPooledDataSource postgres2 = new ComboPooledDataSource("postgres");
ReentrantLock lock = new ReentrantLock();
new Thread(new SourceGetConn2(source, lock), "source").start();
new Thread(new SourceGetConn2(source2, lock), "source2").start();
Thread.sleep(1000);
new Thread(new DestGetConn2(postgres, lock), "postgres").start();
new Thread(new DestGetConn2(postgres2, lock), "postgres2").start();
}
}
class SourceGetConn2 implements Runnable {
private ComboPooledDataSource source = null;
private ReentrantLock lock;
public SourceGetConn2(ComboPooledDataSource source, ReentrantLock lock) {
this.source = source;
this.lock = lock;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
lock.lock();
source.getConnection();
lock.unlock();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
class DestGetConn2 implements Runnable {
private ComboPooledDataSource postgres = null;
private ReentrantLock lock;
public DestGetConn2(ComboPooledDataSource source, ReentrantLock lock) {
this.postgres = source;
this.lock = lock;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(1000);
lock.lock();
postgres.getConnection();
lock.unlock();
System.out.println("I get a Connection! I am in " + Thread.currentThread().getName());
} catch (InterruptedException | SQLException e) {
e.printStackTrace();
}
}
}
}
5.最后总结一个效率还可以的工具类
package com.highgo.hgdbadmin.myutil;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3P0Util {
public static String SOURCE = "source";
public static String POSTGRES = "postgres";
private ComboPooledDataSource source = null;
private ComboPooledDataSource postgres = null;
private static C3P0Util instance = null;
private C3P0Util() {
source = new ComboPooledDataSource("source");
postgres = new ComboPooledDataSource("postgres");
}
public static final synchronized C3P0Util getInstance() {
if (instance == null) {
instance = new C3P0Util();
}
return instance;
}
public synchronized Connection getConnection(String dataSource) throws SQLException {
if ("source".equals(dataSource)) {
return source.getConnection();
} else if ("postgres".equals(dataSource)) {
return postgres.getConnection();
}
return null;
}
public synchronized void close(Connection conn) {
try {
if (conn != null) {
conn.close();
conn = null;
}
} catch (SQLException e) {
}
}
public synchronized void close(Statement stat) {
try {
if (stat != null) {
stat.close();
stat = null;
}
} catch (SQLException e) {
}
}
public synchronized void close(ResultSet rest) {
try {
if (rest != null) {
rest.close();
rest = null;
}
} catch (SQLException e) {
}
}
public static void main(String[] args) {
new Thread(new TestThread(), "test").start();
}
private static class TestThread implements Runnable {
private String dataSource = "source";
@Override
public void run() {
while (true) {
try {
Connection conn = C3P0Util.getInstance().getConnection("");
System.out.println("hello,this is " + dataSource);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if ("source".equals(dataSource)) {
dataSource = "postgres";
} else {
dataSource = "source";
}
}
}
}
}
陳述
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
电源BI无法连接，尝试连接时遇到错误Feb 18, 2024 pm 05:48 PM当PowerBI无法连接到XLS、SQL或Excel文件的数据源时，可能会遇到困难。本文将探讨可能的解决方案，以帮助您解决这一问题。如果您在连接过程中遇到错误或连接失败的情况，本文将指导您采取一些措施。因此，如果您面临这个问题，请继续阅读，我们将为您提供一些有用的建议。PowerBI中的网关连接错误是什么？PowerBI中的网关错误通常是由数据源信息与底层数据集不匹配引起的。要解决这个问题，需要确保本地数据网关上定义的数据源与PowerBI桌面中指定的数据源是准确且一致的。PowerBI无法连接
如何解决 VS Code 中 IntelliSense 不起作用的问题Apr 21, 2023 pm 07:31 PM最常称为VSCode的VisualStudioCode是开发人员用于编码的工具之一。Intellisense是VSCode中包含的一项功能，可让编码人员的生活变得轻松。它提供了编写代码的建议或工具提示。这是开发人员更喜欢的一种扩展。当IntelliSense不起作用时，习惯了它的人会发现很难编码。你是其中之一吗？如果是这样，请通过本文找到不同的解决方案来解决IntelliSense在VS代码中不起作用的问题。Intellisense如下所示。它在您编码时提供建议。首先检
为什么我的Go程序无法正确使用Xorm框架？Jun 09, 2023 pm 06:15 PM作为一门快速发展的编程语言，Go语言在开发速度和性能方面都具备了优秀的表现，越来越多的开发者也在使用它开发自己的项目。而在Go开发中，使用框架可以极大地提高开发效率和代码质量，而Xorm框架是其中受欢迎的一种。然而，在使用Xorm框架过程中，可能会遇到一些问题。本文就是针对一个常见的问题，即“为什么我的Go程序无法正确使用Xorm框架？”，提出一些解决方案和
MySQL连接发生错误1045，该如何处理？Jun 29, 2023 pm 08:49 PMMySQL是一个常用的开源关系型数据库管理系统，许多应用程序和网站都使用MySQL作为其后端数据库。然而，有时当我们尝试连接到MySQL时，可能会遇到错误1045。错误1045意味着访问被拒绝，这通常是由于提供的用户名或密码不正确引起的。当我们在连接MySQL数据库时首次设置密码时，我们可能会遇到此错误。为解决这个问题，我们可以采取以下几个步骤：确认用户名和
如何处理Linux系统中频繁出现的服务器负载过高问题Jun 29, 2023 pm 11:56 PM如何处理Linux系统中频繁出现的服务器负载过高问题摘要：本文介绍了如何处理Linux系统中频繁出现的服务器负载过高问题。通过优化系统配置、调整服务资源分配、检测问题进程和运行性能调优等方法，可以有效降低负载并提高服务器的性能和稳定性。一、引言服务器负载过高是Linux系统中常见的问题之一，会导致服务器运行缓慢、响应不及时，甚至无法正常工作。面对这个问题，我
golang函数并发控制中死锁与饥饿的预防与解决Apr 24, 2024 pm 01:42 PMGo中死锁和饥饿：预防与解决死锁：协程相互等待而无法进行的操作，使用runtime.SetBlockProfileRate函数检测。预防死锁：使用细粒度加锁、超时、无锁数据结构，防止死锁。饥饿：协程持续无法获得资源，使用公平锁防止饥饿。公平锁实践：创建公平锁并等待协程尝试获取锁的时间最长的优先获取锁。
如何处理C++开发中的死锁问题Aug 22, 2023 pm 02:24 PM如何处理C++开发中的死锁问题死锁是多线程编程中常见的问题之一，尤其是在使用C++进行开发时更容易遇到。当多个线程互相等待对方持有的资源时，就可能发生死锁问题。如果不及时处理，死锁不仅会导致程序卡死，还会影响系统的性能和稳定性。因此，学习如何处理C++开发中的死锁问题是非常重要的。一、理解死锁的原因要解决死锁问题，首先需要了解死锁产生的原因。死锁通常发生在以
使用MyBatis实现批量Insert操作的步骤详解Feb 22, 2024 pm 08:27 PM标题：如何使用MyBatis实现批量Insert操作MyBatis是一款优秀的持久层框架，广泛应用于Java开发中。在实际开发中，经常会遇到需要批量插入数据的情况，本文将详细介绍如何使用MyBatis来实现批量Insert操作，并附带具体的代码示例。步骤一：配置MyBatis在项目中引入MyBatis，并配置MyBatis的相关信息，包括数据库连接信息、Ma
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
AI Hentai Generator
免費產生 AI 無盡。
熱門文章
R.E.P.O.能量晶體解釋及其做什麼（黃色晶體）
2 週前By尊渡假赌尊渡假赌尊渡假赌
倉庫：如何復興隊友
4 週前By尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒險：如何獲得巨型種子
3 週前By尊渡假赌尊渡假赌尊渡假赌
擊敗分裂小說需要多長時間？
3 週前ByDDD
R.E.P.O.保存文件位置：在哪里以及如何保護它？
3 週前ByDDD
熱工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
SublimeText3 Linux新版
SublimeText3 Linux最新版
SecLists
SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合，這些清單在安全評估過程中經常使用，而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表，幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上，他就可以存取所需的每種類型的清單。
WebStorm Mac版
好用的JavaScript開發工具
SublimeText3 英文版
推薦：為Win版本，支援程式碼提示！
