code: private Runnable createProcessRunner(final BlockingQueue<FlowletProcessEntry<?>> processQueue,
                                         final List<FlowletProcessEntry<?>> processList,
                                         final ClassLoader classLoader) {
      return new Runnable() {
        @Override
        public void run() {
          Thread.currentThread().setContextClassLoader(classLoader);
          for (FlowletProcessEntry<?> entry : processList) {
            if (!handleProcessEntry(entry, processQueue)) {
              processQueue.offer(entry);
            }
          }
        }
      };
    }
docs: Creates a {@link Runnable} for execution of calling flowlet process methods.