elasticsearch高階配置之(二)----執行緒池設定
阿新 • • 發佈:2019-02-02
一個Elasticsearch節點會有多個執行緒池,但重要的是下面四個:
索引(index):主要是索引資料和刪除資料操作(預設是cached型別)
搜尋(search):主要是獲取,統計和搜尋操作(預設是cached型別)
批量操作(bulk):主要是對索引的批量操作(預設是cached型別)
更新(refresh):主要是更新操作(預設是cached型別)
可以通過給設定一個引數來改變執行緒池的型別(type),例如,把索引的執行緒池改成blocking型別:
Java程式碼
下面是三種可以設定的執行緒池的型別
cache
cache執行緒池是一個無限大小的執行緒池,如果有很請求的話都會建立很多執行緒,下面是個例子:
Java程式碼
fixed
fixed執行緒池保持固定個數的執行緒來處理請求佇列。
size引數設定執行緒的個數,預設設定是cpu核心數的5倍
queue_size可以控制待處理請求佇列的大小。預設是設定為-1,意味著無限制。當一個請求到來但佇列滿了的時候,reject_policy引數可以控制它的行為。預設是abort,會使那個請求失敗。設定成caller會使該請求在io執行緒中執行。
Java程式碼
blocking
blocking執行緒池允許設定一個最小值(min,預設為1)和執行緒池大小(size,預設為cpu核心數的5倍)。它也有一個等待佇列,佇列的大小(queue_size )預設是1000,當這佇列滿了的時候。它會根據定好的等待時間(wait_time,預設是60秒)來呼叫io執行緒,如果沒有執行就會報錯。
Java程式碼
索引(index):主要是索引資料和刪除資料操作(預設是cached型別)
搜尋(search):主要是獲取,統計和搜尋操作(預設是cached型別)
批量操作(bulk):主要是對索引的批量操作(預設是cached型別)
更新(refresh):主要是更新操作(預設是cached型別)
可以通過給設定一個引數來改變執行緒池的型別(type),例如,把索引的執行緒池改成blocking型別:
Java程式碼
- threadpool:
- index:
- type: blocking
- min: 1
-
size: 30
- wait_time: 30s
下面是三種可以設定的執行緒池的型別
cache
cache執行緒池是一個無限大小的執行緒池,如果有很請求的話都會建立很多執行緒,下面是個例子:
Java程式碼
- threadpool:
- index:
- type: cached
fixed
fixed執行緒池保持固定個數的執行緒來處理請求佇列。
size引數設定執行緒的個數,預設設定是cpu核心數的5倍
queue_size可以控制待處理請求佇列的大小。預設是設定為-1,意味著無限制。當一個請求到來但佇列滿了的時候,reject_policy引數可以控制它的行為。預設是abort,會使那個請求失敗。設定成caller會使該請求在io執行緒中執行。
Java程式碼
- threadpool:
- index:
- type: fixed
- size: 30
- queue: 1000
- reject_policy: caller
blocking
blocking執行緒池允許設定一個最小值(min,預設為1)和執行緒池大小(size,預設為cpu核心數的5倍)。它也有一個等待佇列,佇列的大小(queue_size )預設是1000,當這佇列滿了的時候。它會根據定好的等待時間(wait_time,預設是60秒)來呼叫io執行緒,如果沒有執行就會報錯。
Java程式碼
-
threadpool:
- index:
- type: blocking
- min: 1
- size: 30
- wait_time: 30s