org.I0Itec.zkclient.ZkLock类的使用及代码示例

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

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

ZkLock介绍

暂无

代码示例

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

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: 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 void setCurrentState(KeeperState currentState) {
 getEventLock().lock();
 try {
  _currentState = currentState;
 } 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: org.apache.helix/helix-core

LOG.trace("closing a zkclient. callStack: " + Arrays.asList(calls));
getEventLock().lock();
try {
 if (_connection == null || _closed) {
 getEventLock().getStateChangedCondition().signalAll();
 getEventLock().unlock();
 if (_monitor != null) {
  _monitor.unregister();

代码示例来源：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

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

代码示例来源：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: apache/helix

public boolean waitUntilExists(String path, TimeUnit timeUnit, long time)
  throws ZkInterruptedException {
 Date timeout = new Date(System.currentTimeMillis() + timeUnit.toMillis(time));
 if (LOG.isDebugEnabled()) {
  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: apache/helix

LOG.trace("closing a zkclient. callStack: " + Arrays.asList(calls));
getEventLock().lock();
IZkConnection connection = getConnection();
try {
 getEventLock().getStateChangedCondition().signalAll();
 getEventLock().unlock();
 if (_monitor != null) {
  _monitor.unregister();

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

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: org.apache.helix/helix-core

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

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

|| 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 void setCurrentState(KeeperState currentState) {
  getEventLock().lock();
  try {
    _currentState = currentState;
  } 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.alibaba.otter/shared.common

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: 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: apache/helix

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

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

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

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

ZkLock

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com