code: public void run() {
      lock.readLock().lock();
      try {
        if (Collections.isEmptyCollection(listeners)) {
          return;
        }
        for (ProcessorListener listener : listeners) {
          executorService.execute(listener);
        }
      } finally {
        lock.readLock().unlock();
      }
    }
docs: starts the processor listeners.