作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.accumulo.fate.ZooStore._getStatus()
方法的一些代码示例,展示了ZooStore._getStatus()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooStore._getStatus()
方法的具体详情如下:
包路径:org.apache.accumulo.fate.ZooStore
类名称:ZooStore
方法名:_getStatus
暂无
代码示例来源:origin: apache/accumulo
@Override
public TStatus getStatus(long tid) {
verifyReserved(tid);
return _getStatus(tid);
}
代码示例来源:origin: apache/accumulo
@Override
public TStatus waitForStatusChange(long tid, EnumSet<TStatus> expected) {
while (true) {
long events;
synchronized (this) {
events = statusChangeEvents;
}
TStatus status = _getStatus(tid);
if (expected.contains(status))
return status;
synchronized (this) {
if (events == statusChangeEvents) {
try {
this.wait(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
}
代码示例来源:origin: org.apache.accumulo/accumulo-fate
@Override
public TStatus waitForStatusChange(long tid, EnumSet<TStatus> expected) {
while (true) {
long events;
synchronized (this) {
events = statusChangeEvents;
}
TStatus status = _getStatus(tid);
if (expected.contains(status))
return status;
synchronized (this) {
if (events == statusChangeEvents) {
try {
this.wait(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
}
}
代码示例来源:origin: org.apache.accumulo/accumulo-fate
@Override
public TStatus getStatus(long tid) {
verifyReserved(tid);
return _getStatus(tid);
}
本文整理了Java中org.apache.accumulo.fate.ZooStore._getStatus()方法的一些代码示例,展示了ZooStore._getStatus()的具体用法。这些代码
我是一名优秀的程序员,十分优秀!