/ / limit number of thread em ThreadPool ao criar TransportClient em elasticsearch - java, multithreading, elasticsearch

Limite o número de segmentos no ThreadPool ao criar o TransportClient no elasticsearch - java, multithreading, elasticsearch

Eu estou criando uma instância TransportClient emelasticsearch. Abaixo está o código para o mesmo. O problema é que eu estou tentando diminuir o número de threads gerado com o threadpool que TransportClient inicia.Mas quais configurações sempre usar meu elasticsearch sempre rubricando o threadpool com 12 threads.Por favor, deixe-me saber como configurar o mesmo para obter o desejável tópicos.

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;
}

Respostas:

1 para resposta № 1

Experimentar

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

Crédito para JanuZ, retirado de http://www.lucidelectricdreams.com/2013/11/reducing-number-of-threads-created-by.html