从 EntryProcessor 访问 IMap

Question

可以从 EntryProcessor 的 process() 方法中访问 IMap 或其他 Hazelcast 分布式数据结构（如 AtomicLong）吗？

我遇到以下异常：

java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException: Thread[hz.Alcatraz-ANP-Sys-HAZLE-2.actiance.local.partition-operation.thread-5,5,Alcatraz-ANP-Sys-HAZLE-2.actiance.local] cannot make remote call: com.hazelcast.concurrent.lock.operations.LockOperation@3229190f
at java.util.concurrent.FutureTask.report(FutureTask.java:122) ~[na:1.7.0_51]
at java.util.concurrent.FutureTask.get(FutureTask.java:188) ~[na:1.7.0_51]
at com.hazelcast.executor.impl.DistributedExecutorService$CallableProcessor.run(DistributedExecutorService.java:189) ~[hazelcast-3.3_actiance.jar:3.3]
at com.hazelcast.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:209) [hazelcast-3.3_actiance.jar:3.3]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_51]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_51]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) [hazelcast-3.3_actiance.jar:3.3]
at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:92) [hazelcast-3.3_actiance.jar:3.3]

我正在使用 Hazelcast 3.3 版

Answer 1

您可以访问其他数据结构，但您需要确保它们与当前处理的条目位于同一数据分区中。这意味着您可以使用（例如）数据亲和力将所有数据固定在同一分区中。

虽然在不同分区之间共享 IAtomicLong 是不可能的。

PS：除了当前处理的条目之外，您也不应该改变其他数据，因为它可能最终导致不同节点之间的死锁。

从 EntryProcessor 访问 IMap

accessing IMap from EntryProcessor

hazelcast