我打算通过亲和键将大量小任务提交到节点中。
Object affKey;
IgniteRunnable job;
//...
ignite.compute.affinityRun("cache", affKey, job);
问题是给定作业在每个节点上的哪个线程池中执行?如何配置其中的线程数量?
所有计算任务都在 publicThreadPool 中执行。您可以使用 IgniteConfiguration.setPublicThreadPoolSize 对其进行配置。
另外,从 ignite-2.0 开始,您可以定义 customThreadPool。您可以在文档中找到示例。