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

ZooKeeperOperation介绍

[英]A callback object which can be used for implementing retry-able operations in the org.apache.zookeeper.recipes.lock.ProtocolSupport class
[中]

代码示例

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

/**
 * Perform the given operation, retrying if the connection fails
 * @return object. it needs to be cast to the callee's expected 
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation) 
  throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: " + zookeeper + " so reconnecting due to: " + e, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt " + i + " failed with connection loss so " +
          "attempting to reconnect: " + e, e);
      retryDelay(i);
    }
  }
  throw exception;
}

代码示例来源：origin: knightliao/disconf

/**
 * Perform the given operation, retrying if the connection fails
 *
 * @return object. it needs to be cast to the callee's expected
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation) throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: " + zookeeper + " so reconnecting due to: " + e, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt " + i + " failed with connection loss so " +
             "attempting to reconnect: " + e, e);
      retryDelay(i);
    }
  }
  throw exception;
}

代码示例来源：origin: knightliao/disconf

zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Caught: " + e, e);

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

zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Caught: " + e, e);

代码示例来源：origin: com.baidu.disconf/disconf-core

/**
 * Perform the given operation, retrying if the connection fails
 *
 * @return object. it needs to be cast to the callee's expected
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation) throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: " + zookeeper + " so reconnecting due to: " + e, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt " + i + " failed with connection loss so " +
             "attempting to reconnect: " + e, e);
      retryDelay(i);
    }
  }
  throw exception;
}

代码示例来源：origin: io.teknek/teknek-core

/**
 * Perform the given operation, retrying if the connection fails
 * @return object. it needs to be cast to the callee's expected 
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation) 
  throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: " + zookeeper + " so reconnecting due to: " + e, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt " + i + " failed with connection loss so " +
          "attempting to reconnect: " + e, e);
      retryDelay(i);
    }
  }
  throw exception;
}

代码示例来源：origin: edwardcapriolo/IronCount

/**
 * Perform the given operation, retrying if the connection fails
 * @return object. it needs to be cast to the callee's expected
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation)
  throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: " + zookeeper + " so reconnecting due to: " + e, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt " + i + " failed with connection loss so " +
          "attempting to reconnect: " + e, e);
      retryDelay(i);
    }
  }
  throw exception;
}

代码示例来源：origin: sleberknight/zookeeper-samples

/**
 * Perform the given operation, retrying if the connection fails
 * @return object. it needs to be cast to the callee's expected 
 * return type.
 */
protected Object retryOperation(ZooKeeperOperation operation)
  throws KeeperException, InterruptedException {
  KeeperException exception = null;
  for (int i = 0; i < retryCount; i++) {
    try {
      return operation.execute();
    } catch (KeeperException.SessionExpiredException e) {
      LOG.warn("Session expired for: {} so reconnecting", zookeeper, e);
      throw e;
    } catch (KeeperException.ConnectionLossException e) {
      if (exception == null) {
        exception = e;
      }
      LOG.debug("Attempt {} failed with connection loss so attempting to reconnect", i, e);
      retryDelay(i);
    }
  }
  if (isNull(exception)) {
    throw new IllegalStateException("The KeeperException was (unexpectedly) null; cannot throw it!");
  }
  throw exception;
}

代码示例来源：origin: com.baidu.disconf/disconf-core

zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Caught: " + e, e);

代码示例来源：origin: io.teknek/teknek-core

zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Caught: " + e, e);

代码示例来源：origin: edwardcapriolo/IronCount

zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Caught: " + e, e);

代码示例来源：origin: sleberknight/zookeeper-samples

return Boolean.TRUE;
  };
  zopdel.execute();
} catch (InterruptedException e) {
  LOG.warn("Interrupted", e);