-
Notifications
You must be signed in to change notification settings - Fork 434
Barrier
Randgalt edited this page Dec 6, 2011
·
2 revisions
An implementation of the Distributed Barrier ZK recipe.
Distributed systems use barriers to block processing of a set of nodes until a condition is met at which time all the nodes are allowed to proceed.
- DistributedBarrier
public DistributedBarrier(CuratorFramework client,
String barrierPath)
Parameters:
client - client
barrierPath - path to use as the barrier
To wait on the barrier:
public void waitOnBarrier()
There are utilities for setting/removing the barrier:
setBarrier();
removeBarrier();
DistributedBarrier instances watch for connection loss and will throw an exception from waitOnBarrier().
- Curator
- Javadoc
- Coverage Report
- Getting Started
- Examples
- FAQ
- Client
- Framework
-
Recipes
- Leader Latch
- Leader Election
- Shared Reentrant Lock
- Shared Lock
- Shared Reentrant Read Write Lock
- Shared Semaphore
- Multi Shared Lock
- Distributed Queue
- Distributed Id Queue
- Distributed Priority Queue
- Distributed Delay Queue
- Simple Distributed Queue
- Barrier
- Double Barrier
- Shared counter
- Distributed Atomic Long
- Path Cache
- Node Cache
- Utilities – Test Server, Test Cluster, ZKPaths, EnsurePath, QueueSharder, Reaper, ChildReaper
- Tech Notes
- Errors
- Exhibitor Integration
- Extensions
- Logging and Tracing