Вычислить задачу с запросом из кеша

Question

Я новичок в Apache Ignite (использую 2.7), и я ищу, чтобы создать набор вычислительных задач, которые также запрашивают данные из кэша. Я вижу в документах концепцию совместной обработки, но я не вижу примеров в репо. Пара вещей, по которым мне неясно:

1) Я хочу запросить кэш изнутри задачи, нужно ли мне создать еще один экземпляр Cache с помощью Ignite.start или режима клиента из этой задачи, или есть какая-то неявная переменная, которую я могу использовать из контекста для запросить кеш.

2) В частности, я хотел бы выполнить эту задачу в результате обратного вызова Continuous Query, есть ли какой-нибудь пример, детализирующий это?

спасибо

Answer 1

1. Вы должны внедрить экземпляр Ignite в вашу задачу - это предпочтительный подход.

2. Это может быть сложно - убедитесь, что вы не запускаете эту задачу синхронно, так как вы не должны получать никаких блокировок от обратного вызова Continuous Query. Может быть, методы Async () в порядке. Предпочтительным подходом является планирование тактов в вашем собственном пуле потоков для обработки последних и возврата из обратного вызова. Убедитесь, что вы не ожидаете пул потоков, поскольку он исчерпывает себя (поскольку общая стратегия состоит в том, чтобы выполнять задачу синхронно, если пул заполнен).