在elasticsearch中創建TransportClient時限制ThreadPool中的線程數

Question

我正在elasticsearch中創建一個TransportClient實例。以下是相同的代碼。問題是我試圖降低由線程池產生的線程數量，即由TransportClient啓動。但是我使用我的elasticsearch總是使用12個線程初始化線程池。請讓我知道如何配置相同的，以獲得理想的線程。

public static TransportClient getTransportClient(String ip, int port) { 

    ImmutableSettings.Builder settings = ImmutableSettings 
      .settingsBuilder(); 
    settings.put("cluster.name", "elasticsearch"); 
    settings.put("threadpool.bulk.type", "fixed"); 
    settings.put("threadpool.bulk.size" ,5); 
    settings.put("threadpool.bulk.queue_size", 5); 
    settings.put("threadpool.index.type" , "fixed"); 
    settings.put("threadpool.index.size" , 5); 
    settings.put("threadpool.index.queue_size" , 10); 
    settings.put("threadpool.search.type", "fixed"); 
    settings.put("threadpool.search.size" ,5); 
    settings.put("threadpool.search.queue_size", 5); 

    settings.build(); 

    TransportClient instance = new TransportClient(settings) 
      .addTransportAddress(new InetSocketTransportAddress(ip, port)); 

    return instance; 
} 

Answer 1

嘗試

Settings settings = ImmutableSettings.settingsBuilder() 
        .put("transport.netty.workerCount",NUM_THREADS) 
        .build(); 

感謝JanuZ，從http://www.lucidelectricdreams.com/2013/11/reducing-number-of-threads-created-by.html