org.apache.shardingsphere.data.pipeline.core.util

类 PipelineDistributedBarrier

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.util.PipelineDistributedBarrier

public final class PipelineDistributedBarrier
extends Object

Pipeline distributed barrier.

构造器概要

构造器

构造器和说明
PipelineDistributedBarrier()

方法概要

限定符和类型	方法和说明
boolean	await(String parentPath, long timeout, TimeUnit timeUnit) Await until all children node is ready.
void	checkChildrenNodeCount(org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEvent event) Check child node count equal shardingCount.
static PipelineDistributedBarrier	getInstance() Get instance.
void	persistEphemeralChildrenNode(String parentPath, int shardingItem) Persist ephemeral children node.
void	register(String parentPath, int totalCount) Register count down latch.
void	removeParentNode(String parentPath) Persist ephemeral children node.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

PipelineDistributedBarrier

public PipelineDistributedBarrier()

方法详细资料

getInstance

public static PipelineDistributedBarrier getInstance()

Get instance.

返回:

instance

register

public void register(String parentPath,
                     int totalCount)

Register count down latch.

参数:

parentPath - parent path

totalCount - total count

persistEphemeralChildrenNode

public void persistEphemeralChildrenNode(String parentPath,
                                         int shardingItem)

Persist ephemeral children node.

参数:

parentPath - parent path

shardingItem - sharding item

removeParentNode

public void removeParentNode(String parentPath)

Persist ephemeral children node.

参数:

parentPath - parent path

await

public boolean await(String parentPath,
                     long timeout,
                     TimeUnit timeUnit)

Await until all children node is ready.

参数:

parentPath - parent path

timeout - timeout

timeUnit - time unit

返回:

true if the count reached zero and false if the waiting time elapsed before the count reached zero

checkChildrenNodeCount

public void checkChildrenNodeCount(org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEvent event)

Check child node count equal shardingCount.

参数:

event - event