【发布时间】:2015-09-02 17:04:05
【问题描述】:
我正在使用 IMap 进行锁定,按照此处的说明进行操作:
https://groups.google.com/forum/#!topic/hazelcast/9YFGh3xwe8I
IMap<Object, Object> locks = hazelcastInstance.getMap("locks");
locks.lock(someStr);
try {
//do stuff
} finally {
locks.unlock(someStr);
}
偶尔会有一行
locks.locks(someStr)
导致错误
com.hazelcast.core.HazelcastException: java.lang.InterruptedException:
Call BasicInvocation{ serviceName='hz:impl:lockService',op=com.hazelcast.concurrent.lock.operations.LockOperation{
serviceName='hz:impl:lockService', callId=2854669, invocationTime=1441146297670, waitTimeout=-900001, callTimeout=60000},
partitionId=215, replicaIndex=0, tryCount=250, tryPauseMillis=500, invokeCount=0, callTimeout=60000,
target=Address[*.*.*.*]:****, backupsExpected=0, backupsCompleted=0} was interrupted
at com.hazelcast.util.ExceptionUtil.rethrow(ExceptionUtil.java:52)
at com.hazelcast.spi.impl.BasicInvocationFuture.getSafely(BasicInvocationFuture.java:200)
at com.hazelcast.concurrent.lock.LockProxySupport.lock(LockProxySupport.java:79)
at com.hazelcast.concurrent.lock.LockProxySupport.lock(LockProxySupport.java:73)
at com.hazelcast.map.impl.proxy.MapProxyImpl.lock(MapProxyImpl.java:256)
生产中的集群由两个节点组成。
我无法在本地重现该问题。
我读过一个类似的例外,它与应用服务器时钟时间远远不同步有关,但对我来说不是这样。
谁能解释为什么会这样?
看来我对 IMap 的使用非常简单。
【问题讨论】:
标签: hazelcast