org.I0Itec.zkclient.ZkClient.getEventLock()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(146)

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

ZkClient.getEventLock介绍

暂无

代码示例

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

public void setCurrentState(KeeperState currentState) {
  getEventLock().lock();
  try {
    _currentState = currentState;
  } finally {
    getEventLock().unlock();
  }
}

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

public void setCurrentState(KeeperState currentState) {
  getEventLock().lock();
  try {
    _currentState = currentState;
  } finally {
    getEventLock().unlock();
  }
}

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

private void acquireEventLock() {
  try {
    getEventLock().lockInterruptibly();
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

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

private void acquireEventLock() {
  try {
    getEventLock().lockInterruptibly();
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

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

private void reconnect() {
  getEventLock().lock();
  try {
    _connection.close();
    _connection.connect(this);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

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

public long getCreationTime(String path) {
  try {
    getEventLock().lockInterruptibly();
    return _connection.getCreateTime(path);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } 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.github.sgroschupf/zkclient

private void reconnect() {
  getEventLock().lock();
  try {
    _connection.close();
    _connection.connect(this);
  } 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: com.101tec/zkclient

|| event.getType() == EventType.NodeChildrenChanged;
getEventLock().lock();
try {
    getEventLock().getStateChangedCondition().signalAll();
      getEventLock().getZNodeEventCondition().signalAll();
      getEventLock().getDataChangedCondition().signalAll();
    getEventLock().getZNodeEventCondition().signalAll();
    getEventLock().getDataChangedCondition().signalAll();
  getEventLock().unlock();
  LOG.debug("Leaving process event");

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

public boolean waitUntilExists(String path, TimeUnit timeUnit, long time) throws ZkInterruptedException {
  Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
  LOG.debug("Waiting until znode '" + path + "' becomes available.");
  if (exists(path)) {
    return true;
  }
  acquireEventLock();
  try {
    while (!exists(path, true)) {
      boolean gotSignal = getEventLock().getZNodeEventCondition().awaitUntil(timeout);
      if (!gotSignal) {
        return false;
      }
    }
    return true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

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

public boolean waitUntilExists(String path, TimeUnit timeUnit, long time) throws ZkInterruptedException {
  Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
  LOG.debug("Waiting until znode '" + path + "' becomes available.");
  if (exists(path)) {
    return true;
  }
  acquireEventLock();
  try {
    while (!exists(path, true)) {
      boolean gotSignal = getEventLock().getZNodeEventCondition().awaitUntil(timeout);
      if (!gotSignal) {
        return false;
      }
    }
    return true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

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

|| event.getType() == EventType.NodeChildrenChanged;
getEventLock().lock();
try {
    getEventLock().getStateChangedCondition().signalAll();
      getEventLock().getZNodeEventCondition().signalAll();
      getEventLock().getDataChangedCondition().signalAll();
    getEventLock().getZNodeEventCondition().signalAll();
    getEventLock().getDataChangedCondition().signalAll();
  getEventLock().unlock();
  LOG.debug("Leaving process event");

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

/**
 * Close the client.
 * 
 * @throws ZkInterruptedException
 */
public void close() throws ZkInterruptedException {
  if (_connection == null) {
    return;
  }
  LOG.debug("Closing ZkClient...");
  getEventLock().lock();
  try {
    setShutdownTrigger(true);
    _eventThread.interrupt();
    _eventThread.join(2000);
    _connection.close();
    _connection = null;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
  LOG.debug("Closing ZkClient...done");
}

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

/**
 * Close the client.
 * 
 * @throws ZkInterruptedException
 */
public void close() throws ZkInterruptedException {
  if (_closed) {
    return;
  }
  LOG.debug("Closing ZkClient...");
  getEventLock().lock();
  try {
    setShutdownTrigger(true);
    _eventThread.interrupt();
    _eventThread.join(2000);
    _connection.close();
    _closed = true;
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
  LOG.debug("Closing ZkClient...done");
}

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

public long getCreationTime(String path) {
  acquireEventLock();
  try {
    return _connection.getCreateTime(path);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

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

boolean started = false;
try {
  getEventLock().lockInterruptibly();
  setShutdownTrigger(false);
  _eventThread = new ZkEventThread(_connection.getServers());
  throw new IllegalStateException("Not connected with zookeeper server yet. Current state is " + state);
} finally {
  getEventLock().unlock();

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

getEventLock().unlock();

内容来源于网络，如有侵权，请联系作者删除！

zkclient

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ZkClient类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com