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

ZooLock.lockAsync介绍

暂无

代码示例

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

public synchronized boolean tryLock(LockWatcher lw, byte data[])
  throws KeeperException, InterruptedException {
 TryLockAsyncLockWatcher tlalw = new TryLockAsyncLockWatcher(lw);
 lockAsync(tlalw, data);
 if (tlalw.acquiredLock) {
  return true;
 }
 if (asyncLock != null) {
  zooKeeper.recursiveDelete(path + "/" + asyncLock, NodeMissingPolicy.SKIP);
  asyncLock = null;
 }
 return false;
}

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

lockAsync(myLock, lw);

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

lockAsync(asyncLock, lw);

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

private void getMasterLock(final String zMasterLoc) throws KeeperException, InterruptedException {
 log.info("trying to get master lock");
 final String masterClientAddress = hostname + ":"
   + getConfiguration().getPort(Property.MASTER_CLIENTPORT)[0];
 while (true) {
  MasterLockWatcher masterLockWatcher = new MasterLockWatcher();
  masterLock = new ZooLock(getContext().getZooReaderWriter(), zMasterLoc);
  masterLock.lockAsync(masterLockWatcher, masterClientAddress.getBytes());
  masterLockWatcher.waitForChange();
  if (masterLockWatcher.acquiredLock) {
   break;
  }
  if (!masterLockWatcher.failedToAcquireLock) {
   throw new IllegalStateException("master lock in unknown state");
  }
  masterLock.tryToCancelAsyncLockOrUnlock();
  sleepUninterruptibly(TIME_TO_WAIT_BETWEEN_LOCK_CHECKS, TimeUnit.MILLISECONDS);
 }
 setMasterState(MasterState.HAVE_LOCK);
}

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

MoniterLockWatcher monitorLockWatcher = new MoniterLockWatcher();
monitorLock = new ZooLock(zoo, monitorLockPath);
monitorLock.lockAsync(monitorLockWatcher, new byte[0]);

代码示例来源：origin: org.apache.accumulo/accumulo-fate

public synchronized boolean tryLock(LockWatcher lw, byte data[])
  throws KeeperException, InterruptedException {
 TryLockAsyncLockWatcher tlalw = new TryLockAsyncLockWatcher(lw);
 lockAsync(tlalw, data);
 if (tlalw.acquiredLock) {
  return true;
 }
 if (asyncLock != null) {
  zooKeeper.recursiveDelete(path + "/" + asyncLock, NodeMissingPolicy.SKIP);
  asyncLock = null;
 }
 return false;
}

代码示例来源：origin: org.apache.accumulo/accumulo-fate

lockAsync(myLock, lw);

代码示例来源：origin: org.apache.accumulo/accumulo-fate

lockAsync(asyncLock, lw);