如何在 Java 中实现多节点屏障？

Question

我正在用 Java 为学术项目构建一个多节点（分布式）实验设置。我使用脚本在所有节点上启动应用程序。在应用程序启动并启动所有模块后，这些节点开始对分布在这些节点上的共享数据进行一些操作。目前，我在所有模块启动的瞬间和在单个节点启动第一个操作的瞬间之间设置了延迟。尽管这似乎可行，但我希望有一个障碍，以便所有节点都启动它们的模块并前进到障碍。一旦所有节点都前进到屏障，它们就可以开始对共享数据进行操作。

如果有人可以解释如何做或者至少给我指出正确的文档，那将是一个很大的帮助。仅供参考，如果可能的话，我宁愿避免使用信号量。一开始我知道参与实验的节点数量，所以#nodes的这个信息可以用来设置屏障。

谢谢
萨钦

Answer 1

看看 Hazelcast。有一个CyclicBarrier implementation 可用（我没有测试它）。您还可以使用 CountDownLatch 的分布式版本。