使用缓存中的查询计算任务

Question

我是Apache Ignite的新手（使用2.7），我正在寻找创建一组计算任务，同时查询缓存中的数据。我在文档中看到了并置处理的概念，但我没有在回购中看到任何示例。有些事情我不清楚：

1）我想从任务中查询缓存，我是否需要在此任务中使用Ignite.start或Client模式创建另一个Cache实例，或者是否有一些我可以从上下文中使用的隐式变量来查询缓存。

2）具体来说，我想作为Continuous Query回调的结果执行此任务，是否有任何示例详细说明？

谢谢

Answer 1

1. 你应该inject an instance of Ignite进入你的任务 - 这是首选的方法。
2. 这可能很棘手 - 请确保不要同步运行此任务，因为您不应从Continuous Query回调中获取任何锁定。也许Async（）方法没问题。首选方法是将taks安排到您自己的线程池中以处理后续处理，并从回调中返回。确保您不会因为耗尽而等待线程池（因为常见策略是在池已满时同步运行任务）。