- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.isCurrentThreadEventThread()
方法的一些代码示例,展示了ZooKeeperImpl.isCurrentThreadEventThread()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperImpl.isCurrentThreadEventThread()
方法的具体详情如下:
包路径:com.ngdata.sep.util.zookeeper.ZooKeeperImpl
类名称:ZooKeeperImpl
方法名:isCurrentThreadEventThread
暂无
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public void waitForConnection() throws InterruptedException {
if (isCurrentThreadEventThread()) {
throw new RuntimeException("waitForConnection should not be called from within the ZooKeeper event thread.");
}
synchronized (connectedMonitor) {
while (!connected && !stop) {
connectedMonitor.wait();
}
}
if (stop) {
throw new InterruptedException("This ZooKeeper handle is shutting down.");
}
}
代码示例来源:origin: com.ngdata/hbase-sep-impl-common
@Override
public void waitForConnection() throws InterruptedException {
if (isCurrentThreadEventThread()) {
throw new RuntimeException("waitForConnection should not be called from within the ZooKeeper event thread.");
}
synchronized (connectedMonitor) {
while (!connected && !stop) {
connectedMonitor.wait();
}
}
if (stop) {
throw new InterruptedException("This ZooKeeper handle is shutting down.");
}
}
代码示例来源:origin: NGDATA/hbase-indexer
@Override
public <T> T retryOperation(ZooKeeperOperation<T> operation) throws InterruptedException, KeeperException {
if (isCurrentThreadEventThread()) {
throw new RuntimeException("retryOperation should not be called from within the ZooKeeper event thread.");
}
int tryCount = 0;
while (true) {
tryCount++;
try {
return operation.execute();
} catch (KeeperException.ConnectionLossException e) {
// ok
}
if (tryCount > 3) {
log.warn("ZooKeeper operation attempt " + tryCount + " failed due to connection loss.");
}
waitForConnection();
}
}
代码示例来源:origin: com.ngdata/hbase-sep-impl-common
@Override
public <T> T retryOperation(ZooKeeperOperation<T> operation) throws InterruptedException, KeeperException {
if (isCurrentThreadEventThread()) {
throw new RuntimeException("retryOperation should not be called from within the ZooKeeper event thread.");
}
int tryCount = 0;
while (true) {
tryCount++;
try {
return operation.execute();
} catch (KeeperException.ConnectionLossException e) {
// ok
}
if (tryCount > 3) {
log.warn("ZooKeeper operation attempt " + tryCount + " failed due to connection loss.");
}
waitForConnection();
}
}
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.getState()方法的一些代码示例,展示了ZooKeeperImpl.getState(
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.isCurrentThreadEventThread()方法的一些代码示例,展示了ZooKe
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.close()方法的一些代码示例,展示了ZooKeeperImpl.close()的具体用法
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.()方法的一些代码示例,展示了ZooKeeperImpl.()的具体用法。这些代码示例主要来
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.waitForConnection()方法的一些代码示例,展示了ZooKeeperImpl.
我是一名优秀的程序员,十分优秀!