在哪個線程池affinityRun提交任務？如何配置線程數量？

Question

我喜歡通過親和鍵將大量小任務提交到節點。

Object affKey; 
IgniteRunnable job; 
//... 
ignite.compute.affinityRun("cache", affKey, job); 

問題是在哪個threadPool中給定的作業在每個節點上執行？如何配置它中的線程數量？

Answer 1

所有計算任務都在publicThreadPool中執行。您可以使用IgniteConfiguration.setPublicThreadPoolSize對其進行配置。

此外，由於ignite-2.0，您可以定義customThreadPool。示例可以在doc中找到。