假設單線程查詢SQL耗時1S,那么開啟兩個線程查詢SQL理想情況下也是1S多點才對,機器是4核,但是目前結果近乎2倍顯然有異;
暫且不考慮從線程池獲取連接,任務線程核心代碼如下:
@Override
public void run() {
long s = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName() + "準備執(zhí)行");
try (Connection connection = DBUtils.openConnection();
PreparedStatement preparedStatement = connection.prepareStatement(querySql);
ResultSet resultSet = preparedStatement.executeQuery()) {
long e = System.currentTimeMillis();
System.out.println(Thread.currentThread().getName() + "執(zhí)行耗時:" + (e - s));
} catch (Exception e) {
e.printStackTrace();
} finally {
latch.countDown();
}
}
目的是分表查詢采用多線程,使用CountDownLatch,結果匯總,提交任務代碼如下:
CountDownLatch countDownLatch = new CountDownLatch(TABLE_SIZE);
ExecutorService executor = Executors.newFixedThreadPool(TABLE_SIZE);
List<String> names = new LinkedList<>();
long s = System.currentTimeMillis();
System.out.println("獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...");
try {
for (int i = 0; i < TABLE_SIZE; i++) {
Task task = new Task(countDownLatch, names, PRE_SQL + i);
executor.execute(task);
}
countDownLatch.await();
executor.shutdownNow();
} catch (InterruptedException e) {
e.printStackTrace();
}
long e = System.currentTimeMillis();
System.out.println("總耗時:" + (e - s) + "ms");
當指定1個任務時,控制臺輸出:
獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-1準備執(zhí)行
pool-1-thread-1執(zhí)行耗時:708
總耗時:708ms
當指定2個任務時,控制臺輸出:
獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-1準備執(zhí)行
pool-1-thread-2準備執(zhí)行
pool-1-thread-2執(zhí)行耗時:2054
pool-1-thread-1執(zhí)行耗時:2055
總耗時:2057ms
當指定4個任務時,控制臺輸出:
獲取數(shù)據(jù)庫連接成功,準備執(zhí)行SQL...
pool-1-thread-2準備執(zhí)行
pool-1-thread-3準備執(zhí)行
pool-1-thread-1準備執(zhí)行
pool-1-thread-4準備執(zhí)行
pool-1-thread-3執(zhí)行耗時:3189
pool-1-thread-1執(zhí)行耗時:3203
pool-1-thread-2執(zhí)行耗時:3241
pool-1-thread-4執(zhí)行耗時:3245
總耗時:3248ms
在程序運行期間查看mysql,show processlist;
| 136 | root | localhost:50225 | test | Query | 1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_3 |
| 135 | root | localhost:50224 | test | Query | 1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_1 |
| 138 | root | localhost:50227 | test | Query | 1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_0 |
| 137 | root | localhost:50226 | test | Query | 1 | Sending data | SELECT SQL_NO_CACHE `id`, `name` FROM test_2 |
然后SQL狀態(tài)就變成了Writing to net,不知道是否正常,對Mysql不是很懂。
我也試過單線程for循環(huán)6次,耗時出入不大。
單條SQL執(zhí)行差不多在1S左右,現(xiàn)在4條SQL同時執(zhí)行,并沒有在1S多就返回結果,而是在3S多同時結束,那么這里的問題到底是什么原因導致的呢?
The server is writing a packet to the network. This state is called Sending to client as of MySQL 5.7.8.
ref: https://dev.mysql.com/doc/ref...
本地select 超過1S,推測你每次select出的數(shù)據(jù)集比較大,本地的packet設置得過小
在Mysql執(zhí)行下
show global variables like "max_allowed_packet"
解決方案:
max_allowed_packet
北大青鳥APTECH成立于1999年。依托北京大學優(yōu)質雄厚的教育資源和背景,秉承“教育改變生活”的發(fā)展理念,致力于培養(yǎng)中國IT技能型緊缺人才,是大數(shù)據(jù)專業(yè)的國家
達內教育集團成立于2002年,是一家由留學海歸創(chuàng)辦的高端職業(yè)教育培訓機構,是中國一站式人才培養(yǎng)平臺、一站式人才輸送平臺。2014年4月3日在美國成功上市,融資1
北大課工場是北京大學校辦產業(yè)為響應國家深化產教融合/校企合作的政策,積極推進“中國制造2025”,實現(xiàn)中華民族偉大復興的升級產業(yè)鏈。利用北京大學優(yōu)質教育資源及背
博為峰,中國職業(yè)人才培訓領域的先行者
曾工作于聯(lián)想擔任系統(tǒng)開發(fā)工程師,曾在博彥科技股份有限公司擔任項目經(jīng)理從事移動互聯(lián)網(wǎng)管理及研發(fā)工作,曾創(chuàng)辦藍懿科技有限責任公司從事總經(jīng)理職務負責iOS教學及管理工作。
浪潮集團項目經(jīng)理。精通Java與.NET 技術, 熟練的跨平臺面向對象開發(fā)經(jīng)驗,技術功底深厚。 授課風格 授課風格清新自然、條理清晰、主次分明、重點難點突出、引人入勝。
精通HTML5和CSS3;Javascript及主流js庫,具有快速界面開發(fā)的能力,對瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網(wǎng)頁制作和網(wǎng)頁游戲開發(fā)。
具有10 年的Java 企業(yè)應用開發(fā)經(jīng)驗。曾經(jīng)歷任德國Software AG 技術顧問,美國Dachieve 系統(tǒng)架構師,美國AngelEngineers Inc. 系統(tǒng)架構師。