1. 程式人生 > >elasticsearch高階配置之(二)----執行緒池設定

elasticsearch高階配置之(二)----執行緒池設定

一個Elasticsearch節點會有多個執行緒池,但重要的是下面四個: 
索引(index):主要是索引資料和刪除資料操作(預設是cached型別) 
搜尋(search):主要是獲取,統計和搜尋操作(預設是cached型別) 
批量操作(bulk):主要是對索引的批量操作(預設是cached型別) 
更新(refresh):主要是更新操作(預設是cached型別) 
可以通過給設定一個引數來改變執行緒池的型別(type),例如,把索引的執行緒池改成blocking型別: 
Java程式碼  收藏程式碼
  1. threadpool:   
  2.     index:   
  3.         type: blocking   
  4.         min: 1   
  5.         size: 30
       
  6.         wait_time: 30s  

下面是三種可以設定的執行緒池的型別 
cache 
cache執行緒池是一個無限大小的執行緒池,如果有很請求的話都會建立很多執行緒,下面是個例子: 
Java程式碼  收藏程式碼
  1. threadpool:   
  2.     index:   
  3.         type: cached  

fixed 
fixed執行緒池保持固定個數的執行緒來處理請求佇列。 
size引數設定執行緒的個數,預設設定是cpu核心數的5倍 
queue_size可以控制待處理請求佇列的大小。預設是設定為-1,意味著無限制。當一個請求到來但佇列滿了的時候,reject_policy引數可以控制它的行為。預設是abort,會使那個請求失敗。設定成caller會使該請求在io執行緒中執行。 
Java程式碼  收藏程式碼
  1. threadpool:   
  2.     index:   
  3.         type: fixed   
  4.         size: 30   
  5.         queue: 1000   
  6.         reject_policy: caller  

blocking 
blocking執行緒池允許設定一個最小值(min,預設為1)和執行緒池大小(size,預設為cpu核心數的5倍)。它也有一個等待佇列,佇列的大小(queue_size )預設是1000,當這佇列滿了的時候。它會根據定好的等待時間(wait_time,預設是60秒)來呼叫io執行緒,如果沒有執行就會報錯。 
Java程式碼  收藏程式碼
  1. threadpool:   
  2.     index:   
  3.         type: blocking   
  4.         min: 1   
  5.         size: 30   
  6.         wait_time: 30s