affinityRun在哪个线程池提交任务?如何配置线程数?

In which thread pool affinityRun submit a task? How to configure the number of thread?

我打算通过关联键将大量小任务提交到节点中。

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

问题是给定的作业在每个节点上执行在哪个线程池中?如何配置其中的线程数?

所有计算任务都在 publicThreadPool 中执行。您可以使用 IgniteConfiguration.setPublicThreadPoolSize.

配置它

此外,从 ignite-2.0 开始,您可以定义 customThreadPool。您可以在 doc.

中找到示例