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

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

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

ZkLock.unlock介绍

暂无

代码示例

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

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

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

public void setCurrentState(KeeperState currentState) {
  getEventLock().lock();
  try {
    _currentState = currentState;
  } 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: com.github.sgroschupf/zkclient

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

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

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

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

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

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

public boolean isClosed() {
 try {
  getEventLock().lock();
  return _closed;
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源：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.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: 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.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: 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: 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.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: com.alibaba.otter/shared.common

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

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

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

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

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

private void reconnect() {
 getEventLock().lock();
 try {
  ZkConnection connection = ((ZkConnection) getConnection());
  connection.reconnect(this);
 } 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();
 }
}

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

ZkLock

相关文章

    查看更多

    热门标签

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

    最新文章

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