Java 类org.apache.lucene.index.AtomicReader.CoreClosedListener 实例源码

项目:lams    文件:SegmentCoreReaders.java   
private void notifyCoreClosedListeners(Throwable th) {
  synchronized(coreClosedListeners) {
    for (CoreClosedListener listener : coreClosedListeners) {
      // SegmentReader uses our instance as its
      // coreCacheKey:
      try {
        listener.onClose(this);
      } catch (Throwable t) {
        if (th == null) {
          th = t;
        } else {
          th.addSuppressed(t);
        }
      }
    }
    IOUtils.reThrowUnchecked(th);
  }
}
项目:search    文件:SegmentCoreReaders.java   
private void notifyCoreClosedListeners(Throwable th) {
  synchronized(coreClosedListeners) {
    for (CoreClosedListener listener : coreClosedListeners) {
      // SegmentReader uses our instance as its
      // coreCacheKey:
      try {
        listener.onClose(this);
      } catch (Throwable t) {
        if (th == null) {
          th = t;
        } else {
          th.addSuppressed(t);
        }
      }
    }
    IOUtils.reThrowUnchecked(th);
  }
}
项目:read-open-source-code    文件:SegmentCoreReaders.java   
private void notifyCoreClosedListeners(Throwable th) {
  synchronized(coreClosedListeners) {
    for (CoreClosedListener listener : coreClosedListeners) {
      // SegmentReader uses our instance as its
      // coreCacheKey:
      try {
        listener.onClose(this);
      } catch (Throwable t) {
        if (th == null) {
          th = t;
        } else {
          th.addSuppressed(t);
        }
      }
    }
    IOUtils.reThrowUnchecked(th);
  }
}
项目:lams    文件:SegmentCoreReaders.java   
void addCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.add(listener);
}
项目:lams    文件:SegmentCoreReaders.java   
void removeCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.remove(listener);
}
项目:search    文件:SegmentCoreReaders.java   
void addCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.add(listener);
}
项目:search    文件:SegmentCoreReaders.java   
void removeCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.remove(listener);
}
项目:read-open-source-code    文件:SegmentCoreReaders.java   
void addCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.add(listener);
}
项目:read-open-source-code    文件:SegmentCoreReaders.java   
void removeCoreClosedListener(CoreClosedListener listener) {
  coreClosedListeners.remove(listener);
}