code: public void submit(final Collection<Sample> samples) {
          for (final SampleProcessor processor : m_processors) {
              m_executor.execute(new Runnable() {
  
                  @Override
                  public void run() {
                      processor.submit(samples);
                  }
              });
          }
      }
docs: Submits a collection of samples to each of the underlying {@link SampleProcessor}s. Calls to
  {@link DefaultSampleProcessorService#submit(Collection)} are non-blocking unless the pool is unable
  to keep up and the queue becomes full.
  
  @param samples