公司讓做一個全文檢索的專案，我使用的是elasticsearch。但是對效能有很高的要求，為了解決效能問題，我簡直是寢食難安。

es(elasticsearch)沒有使用分散式，單臺的。

開發完測試的時候，查詢慢，吞吐量低。

網友們建議用非同步--使用Callable來實現、webAsyncTask、Deferred方式等，我一一嘗試了之後也沒有明顯效果，使用壓測工具發現使用前後沒有一點提升。

嘗試這些方法花費了我兩天的時間！

在不想使用redis快取的情況下，我想到了多執行緒抱著試一試的心態。

沒想到吞吐量竟然翻了一倍，查詢效率也瞬間提升了兩個檔次，完全達標，所以這裡要記錄一下。

其實就是一個類，放進去即可。

package com.zing.es.sample.config;
 
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
import java.util.concurrent.ThreadPoolExecutor;
 
@Configuration
public class GlobalConfig {
 
 /**
   * 預設執行緒池執行緒池
   *
   * @return Executor
   */
  @Bean
  public ThreadPoolTaskExecutor defaultThreadPool() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    //核心執行緒數目
    executor.setCorePoolSize(16);
    //指定最大執行緒數
    executor.setMaxPoolSize(300);
    //佇列中最大的數目
    executor.setQueueCapacity(50);
    //執行緒名稱字首
    executor.setThreadNamePrefix("defaultThreadPool_");
    //rejection-policy：當pool已經達到max size的時候，如何處理新任務
    //CALLER_RUNS：不在新執行緒中執行任務，而是由呼叫者所在的執行緒來執行
    //對拒絕task的處理策略
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    //執行緒空閒後的最大存活時間
    executor.setKeepAliveSeconds(60);
    //載入
    executor.initialize();
    return executor;
  }
}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。