import org.apache.uima.collection.StatusCallbackListener; //导入依赖的package包/类
public CollectionProcessingEngine createCpe(StatusCallbackListener aListener)
        throws ResourceInitializationException, CpeDescriptorException {
    ResourceManager resMgr = UIMAFramework.newDefaultResourceManager();

    // max errors
    if (maxErrors != 0) {
        for (CpeCasProcessor cpeCasProcessor : cpeDesc
                .getCpeCasProcessors().getAllCpeCasProcessors()) {
            if (maxErrors == -1) // infinite nr errors ok
                cpeCasProcessor.setActionOnMaxError("continue");
            else if (maxErrors > 0)
                cpeCasProcessor.setMaxErrorCount(maxErrors);
        }
    }

    // thread cnt
    if (maxProcessingUnitThreatCount == 0) {
        cpeDesc.getCpeCasProcessors().setPoolSize(3);
    } else {
        cpeDesc.getCpeCasProcessors().setPoolSize(
                maxProcessingUnitThreatCount + 2);
        cpeDesc.setProcessingUnitThreadCount(maxProcessingUnitThreatCount);
    }

    CollectionProcessingEngine cpe = UIMAFramework
            .produceCollectionProcessingEngine(cpeDesc, resMgr, null);
    cpe.addStatusCallbackListener(aListener);
    return cpe;
}
 

import org.apache.uima.collection.StatusCallbackListener; //导入依赖的package包/类
public SimpleRunCPE(CpeDescription cpeDesc) throws ResourceInitializationException {
  LOGGER.info("Instantiating CPE");
  collectionProcessingEngine = UIMAFramework.produceCollectionProcessingEngine(cpeDesc);
  collectionProcessingEngine.addStatusCallbackListener(new StatusCallbackListener() {
    @Override
    public void initializationComplete() {
      LOGGER.info("CPM Initialization Complete");
    }

    @Override
    public void batchProcessComplete() {
      LOGGER.info("Completed " + entityCount + " documents");
      if (size > 0) {
        LOGGER.info("; " + size + " characters");
      }
    }

    @Override
    public void collectionProcessComplete() {
      LOGGER.info("Completed " + entityCount + " documents");
      if (size > 0) {
        LOGGER.info("; " + size + " characters");
      }
      LOGGER.info(
          "PERFORMANCE REPORT \n" + collectionProcessingEngine.getPerformanceReport().toString());

      completionSemaphore.release();
    }

    @Override
    public void paused() {
      LOGGER.info("Paused");
    }

    @Override
    public void resumed() {
      LOGGER.info("Resumed");
    }

    @Override
    public void aborted() {
      LOGGER.error("CPE processing was aborted");

      completionSemaphore.release();
    }

    @Override
    public void entityProcessComplete(CAS aCas, EntityProcessStatus aStatus) {
      List<Exception> exceptions = aStatus.getExceptions();
      LOGGER.debug(aStatus.getStatusMessage());

      for (Exception exception : exceptions) {
        LOGGER.error("Exception processing a CAS: ", exception);
      }
      if (exceptions.size() > 0) {
        throw new RuntimeException("Processing exception");
      }

      entityCount++;
      String docText = aCas.getDocumentText();
      if (docText != null) {
        size += docText.length();
      }
    }
  });
}
 

import org.apache.uima.collection.StatusCallbackListener; //导入依赖的package包/类
/**
 * Sets a callback listener for the notifications the UIMA Collection
 * Processing Management (CPM) emits while it is running.
 * 
 * @param statusCallbackListener
 */
public void setStatusCallbackListener(StatusCallbackListener statusCallbackListener) {
	this.statusCallbackListener = statusCallbackListener;
}