本文整理了Java中org.I0Itec.zkclient.ZkLock.getStateChangedCondition()方法的一些代码示例，展示了ZkLock.getStateChangedCondition()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkLock.getStateChangedCondition()方法的具体详情如下：
包路径：org.I0Itec.zkclient.ZkLock
类名称：ZkLock
方法名：getStateChangedCondition

ZkLock.getStateChangedCondition介绍

暂无

代码示例

代码示例来源：origin: org.apache.helix/helix-core

public boolean waitForKeeperState(KeeperState keeperState, long time, TimeUnit timeUnit)
  throws ZkInterruptedException {
 if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
  throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
 }
 Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
 LOG.debug("Waiting for keeper state " + keeperState);
 acquireEventLock();
 try {
  boolean stillWaiting = true;
  while (_currentState != keeperState) {
   if (!stillWaiting) {
    return false;
   }
   stillWaiting = getEventLock().getStateChangedCondition().awaitUntil(timeout);
  }
  LOG.debug("State is " + (_currentState == null ? "CLOSED" : _currentState));
  return true;
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源：origin: apache/helix

public boolean waitForKeeperState(KeeperState keeperState, long time, TimeUnit timeUnit)
  throws ZkInterruptedException {
 if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
  throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
 }
 Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
 LOG.debug("Waiting for keeper state " + keeperState);
 acquireEventLock();
 try {
  boolean stillWaiting = true;
  while (_currentState != keeperState) {
   if (!stillWaiting) {
    return false;
   }
   stillWaiting = getEventLock().getStateChangedCondition().awaitUntil(timeout);
  }
  LOG.debug("State is " + (_currentState == null ? "CLOSED" : _currentState));
  return true;
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源：origin: com.github.sgroschupf/zkclient

public boolean waitForKeeperState(KeeperState keeperState, long time, TimeUnit timeUnit) throws ZkInterruptedException {
  if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
    throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
  }
  Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
  LOG.debug("Waiting for keeper state " + keeperState);
  acquireEventLock();
  try {
    boolean stillWaiting = true;
    while (_currentState != keeperState) {
      if (!stillWaiting) {
        return false;
      }
      stillWaiting = getEventLock().getStateChangedCondition().awaitUntil(timeout);
    }
    LOG.debug("State is " + _currentState);
    return true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源：origin: com.alibaba.otter/shared.common

public boolean waitForKeeperState(KeeperState keeperState, long time, TimeUnit timeUnit)
                                            throws ZkInterruptedException {
  if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
    throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
  }
  Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
  LOG.debug("Waiting for keeper state " + keeperState);
  acquireEventLock();
  try {
    boolean stillWaiting = true;
    while (_currentState != keeperState) {
      if (!stillWaiting) {
        return false;
      }
      stillWaiting = getEventLock().getStateChangedCondition().awaitUntil(timeout);
    }
    LOG.debug("State is " + _currentState);
    return true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源：origin: com.101tec/zkclient

public boolean waitForKeeperState(KeeperState keeperState, long time, TimeUnit timeUnit) throws ZkInterruptedException {
  if (_zookeeperEventThread != null && Thread.currentThread() == _zookeeperEventThread) {
    throw new IllegalArgumentException("Must not be done in the zookeeper event thread.");
  }
  Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
  LOG.info("Waiting for keeper state " + keeperState);
  acquireEventLock();
  try {
    boolean stillWaiting = true;
    while (_currentState != keeperState) {
      if (!stillWaiting) {
        return false;
      }
      stillWaiting = getEventLock().getStateChangedCondition().awaitUntil(timeout);
      // Throw an exception in the case authorization fails
      if (_currentState == KeeperState.AuthFailed && _isZkSaslEnabled) {
        throw new ZkAuthFailedException("Authentication failure");
      }
    }
    LOG.debug("State is " + _currentState);
    return true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源：origin: org.apache.helix/helix-core

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: org.apache.helix/helix-core

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: com.github.sgroschupf/zkclient

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: com.101tec/zkclient

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: apache/helix

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: com.alibaba.otter/shared.common

getEventLock().getStateChangedCondition().signalAll();

代码示例来源：origin: apache/helix

getEventLock().getStateChangedCondition().signalAll();