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