Java多線程導致CPU占用100%怎么辦

這篇文章給大家分享的是有關Java多線程導致CPU占用100%怎么辦的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

簡介

情景：1000萬表數(shù)據(jù)導入內存數(shù)據(jù)庫，按分頁大小10000查詢，多線程，15條線程跑。
使用了ExecutorService executor = Executors.newFixedThreadPool(15)
本地跑了一段時間后，發(fā)現(xiàn)電腦CPU逐漸升高，最后CPU占用100%卡死，內存使用也高達80%。

排查問題

Debug 發(fā)現(xiàn)雖然創(chuàng)建了定長15的線程池，但是因為數(shù)據(jù)量大，在For中循環(huán)分頁查詢的List會持續(xù)加入LinkedBlockingQueue()
隊列中每一個等待的任務，又加載了1萬的數(shù)據(jù)。所以不管是線程數(shù)的CPU搶占，還是內存的消耗都是極高。
所以是不是能夠控制等待隊列LinkedBlockingQueue的上限就可以了。

解決辦法

使用AtomicLong 統(tǒng)計線程是否完成，再執(zhí)行executor.submit()提交新的任務導隊列中。
偽代碼如下：

private AtomicLong threadNum = new AtomicLong(0);

public void init() throws Exception {
	ExecutorService executor = Executors.newFixedThreadPool(15);

	Integer total = accountMapper.selectCount(new QueryWrapper<>());
	Integer pageSize = 10000;  // 頁大小
	Integer pageCount = (total + pageSize -1) / pageSize; // 總頁數(shù)

	for (Integer start = 1; start <= pageCount; start++) {

		List<Account> list = accountMapper.selectPage(new Page<>(start, pageSize), query).getRecords();

		//等待線程任務完成，設置30，可令運行線程數(shù)為15，等待隊列線程數(shù)為15
		while (threadNum.get() >= 30){
			Thread.sleep(5000);
		}

		//開啟1個線程+1
		threadNum.incrementAndGet();
	
		executor.submit(() -> {

			try {
				// 處理業(yè)務
				dealMessage(list);
				// 任務完成 -1
				threadNum.decrementAndGet();
			} catch (Exception e) {
				e.printStackTrace();
			}

		});

	}
        executor.shutdown();
        executor.awaitTermination(1, TimeUnit.DAYS);

}

效果就是CPU保持在15~45%之間，內存占用也只有45%。

目前只想到這樣的方式，控制等待隊列LinkedBlockingQueue的上限，還有更好的方式請告知，感謝！

2021-02-03-分割線
最近又用到了多線程開發(fā)，發(fā)現(xiàn)了還是有很多方式控制的。簡單的使用java的Semaphore令牌限流控制也能實現(xiàn)。

多線程：

• 線程池必須關閉，main主線程才能結束（接口才會返回）finally { executorService.shutdown(); }

• 主線程等待保證多線程所有子線程任務執(zhí)行完畢，再結束。 -> executorService.awaitTermination(1, TimeUnit.DAYS);

• semaphore 令牌限流控制fixedThread線程池，本例子就是最多同時擁有2個線程進行工作

• fixedThread.execute() fixedThread.submit() 的差別除了后者可以返回結果外，后者還會catch掉異常信息，無法拋到主線程中。

public static void main(String[] args) {
    final List<String> tableNames = new ArrayList<>();
    tableNames.add("a");
    tableNames.add("b");
    tableNames.add("c");
    tableNames.add("d");
    tableNames.add("e");
    tableNames.add("f");

    final Semaphore semaphore = new Semaphore(2);
    final ExecutorService fixedThread = Executors.newCachedThreadPool();
    for (final String tableName : tableNames) {
        //阻塞，獲取令牌
        try {
            semaphore.acquire();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //do
        fixedThread.execute(() -> {  //can throw ex log
            final ExecutorService executorService = Executors.newCachedThreadPool();
            try {
                executorService.submit(() -> { //can't throw ex log
                    //int i = 1/0;
                    System.out.println("tableName2:" + tableName);
                });
                //int i = 1/0;
                System.out.println("tableName:" + tableName);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                executorService.shutdown();
                try {
                    executorService.awaitTermination(1, TimeUnit.DAYS);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                semaphore.release();
                System.out.println("semaphore.release");
            }
        });
    }
    // 記得關閉線程池
    fixedThread.shutdown();
    try {
        fixedThread.awaitTermination(1, TimeUnit.DAYS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("主線程...");
}

打印結果

tableName:b
tableName2:b
tableName:a
tableName2:a
semaphore.release
semaphore.release
tableName:d
tableName2:d
tableName:c
semaphore.release
tableName:e
tableName2:c
semaphore.release
tableName:f
tableName2:e
semaphore.release
tableName2:f
semaphore.release
主線程...

Java的特點有哪些

Java的特點有哪些 1.Java語言作為靜態(tài)面向對象編程語言的代表，實現(xiàn)了面向對象理論，允許程序員以優(yōu)雅的思維方式進行復雜的編程。 2.Java具有簡單性、面向對象、分布式、安全性、平臺獨立與可移植性、動態(tài)性等特點。 3.使用Java可以編寫桌面應用程序、Web應用程序、分布式系統(tǒng)和嵌入式系統(tǒng)應用程序等。

感謝各位的閱讀！關于“Java多線程導致CPU占用100%怎么辦”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！