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

ZkEventThread.interrupt介绍

暂无

代码示例

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

@Override
public void run() {
  LOG.info("Starting ZkClient event thread.");
  try {
    while (!isInterrupted()) {
      ZkEvent zkEvent = _events.take();
      int eventId = _eventId.incrementAndGet();
      LOG.debug("Delivering event #" + eventId + " " + zkEvent);
      try {
        zkEvent.run();
      } catch (InterruptedException e) {
        interrupt();
      } catch (ZkInterruptedException e) {
        interrupt();
      } catch (Throwable e) {
        LOG.error("Error handling event " + zkEvent, e);
      }
      LOG.debug("Delivering event #" + eventId + " done");
    }
  } catch (InterruptedException e) {
    LOG.info("Terminate ZkClient event thread.");
  }
}

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

@Override
public void run() {
  LOG.info("Starting ZkClient event thread.");
  try {
    while (!isInterrupted()) {
      ZkEvent zkEvent = _events.take();
      int eventId = _eventId.incrementAndGet();
      LOG.debug("Delivering event #" + eventId + " " + zkEvent);
      try {
        zkEvent.run();
      } catch (InterruptedException e) {
        interrupt();
      } catch (ZkInterruptedException e) {
        interrupt();
      } catch (Throwable e) {
        LOG.error("Error handling event " + zkEvent, e);
      }
      LOG.debug("Delivering event #" + eventId + " done");
    }
  } catch (InterruptedException e) {
    LOG.info("Terminate ZkClient event thread.");
  }
}

代码示例来源：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.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");
}