C3P0在多線程下的maxPoolSize配置


ETL工具完畢的差點兒相同了。今天遇到一個問題。就是給C3P0配置了maxPoolSize為10。目的是想讓整個應用同一時候獲得的最大的Connection個數為10,可是在測試應用的這一部分之后,發現PostgreSQL端的鏈接遠遠超過10個。由於工具是多線程的。所以就想,是不是多線程的問題,查了一下Connection的個數,也確實是10*線程個數。於是做了一個測試:

將maxPoolSize配置為5。執行以下的程序:

ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");
		for (int i = 0; i < 10; i++) {
		cpds.getConnection();}
ComboPooledDataSource cpds2 = new ComboPooledDataSource("postgres");
		for (int i = 0; i < 10; i++) {
		cpds2.getConnection();}

maxPoolSize配置為5。一共想要獲取20個鏈接,這時查看PostgreSQL Server端的連接數為5,正式預期的結果。

在執行以下的程序:

for (int i = 0; i < 2; i++) {
			new Thread(new Runnable() {

				@Override
				public void run() {
					ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");
					for (int i = 0; i < 10; i++) {
						try {
							cpds.getConnection();
						} catch (SQLException e) {
							e.printStackTrace();
						}
					}
					try {
						Thread.sleep(100000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}

			}, "Thread" + i).start();
		}

兩個線程,每一個線程想要獲取10個鏈接數,這時查看PostgreSQL Server端的鏈接數,是10個。將i<2改為i<3,在執行一次,查看PostgreSQL Server端的連接數是15。

再進行以下的測試:

final ComboPooledDataSource cpds = new ComboPooledDataSource("postgres");
		for (int i = 0; i < 3; i++) {
			new Thread(new Runnable() {
				@Override
				public void run() {
					for (int i = 0; i < 10; i++) {
						try {
							cpds.getConnection();
						} catch (SQLException e) {
							e.printStackTrace();
						}
					}
					try {
						Thread.sleep(100000);
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}, "Thread" + i).start();
		

創建3個線程,每一個線程須要10個Connection,這時查看PostgreSQL Server端的連接數是5。可見,PostgreSQL Server端的鏈接的個數與client創建的ComboPooledDataSource實例的個數成正比。C3P0配置文件里配置的內容都是針對一個ComboPooledDataSource實例的限制。

結論:

底層的原因大概是由於C3P0不是為多線程設計的,在底層JDBC也不是線程安全的。

詳細的原因,有機會在詳細分析。

一個應用中一般一個數據源僅僅用一個ComboPooledDataSource對象,也就是一個ComboPooledDataSource實例。







免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM