private ExecutorService createExecutorService() {
    ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat(CONTAINER_THREAD_NAME_FORMAT).setDaemon(true).build();
    return Executors.newSingleThreadExecutor(threadFactory);
  }
Asynchronously starts this {@link StreamProcessor}.
<p>
  <b>Implementation</b>:
  Starts the {@link JobCoordinator}, which will eventually start the {@link SamzaContainer} when a new
  {@link JobModel} is available.
</p>
samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java