Hi Ilya,
1) Which thread pool is used by compute? (is that the ignite public thread
pool [1])?
I'm now using the following from when I listen to events:
CompletableFuture.runAsync(() -> {
ignite.compute().run(new MyRunnable(event.getValue()))
}, Executors.newFixedThreadPool(10));
This seems to work now but I'm not sure if this is the correct way to handle
the long running events.
2) I think this will will queue all those jobs until a thread (one of the
10) finishes it's job right?
I've also tried with a compute.runAsync and then listen on the future, after
doing the put in the callback method.
3) Which of these is the best approach?
Humphrey
[1] https://apacheignite.readme.io/docs/thread-pools
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/