GridGain支持分布式锁吗?
在我的场景中,我希望在代码中添加分布式锁,并确保只有一个节点同时执行代码。下面是示例代码:
final Grid grid = GridGain.start("config/default-config.xml");
GridCache<Object, Object> cache = grid.cache("partitioned_tx");
ExecutorService exec = grid.compute().executorService();
//Lock here
for(int i=0;i<100;i++){
final int index = i;
exec.submit(new GridRunnable() {
private static final long serialVersionUID = -8705359518901621360L;
@Override
public void run() {
System.out.println("The task-"+index+" is executed on "+grid.forLocal().node().toString());
}
});
}
//unlock here
exec.shutdown();
exec.awaitTermination(0, TimeUnit.MILLISECONDS);谢谢,比尔
发布于 2014-09-13 08:07:33
是的,GridGain支持分布式锁以及分布式事务。请查看基本分布式锁指南中的快速入门文档。
https://stackoverflow.com/questions/25817185
复制相似问题