Conveyor.process("data-process-log", new TariffConveyor(this.setup, this, con),
        Arrays.asList(new FindItemConveyor[] {
        new FindItemConveyor(this.setup, this, processIn, rangeMapCache), new FindItemConveyor(this.setup, this, processIn, rangeMapCache) }));

...

 public static <T, C> void process(String name, Conveyor<T, ? extends ConveyorContext<T>, ? extends ThreadContext> conveyor, List<? extends Callable<C>> tasks)
    throws InterruptedException, ExecutionException
  {
    ExecutorService executorService = WorkerTask.newFixedThreadPool(name, null, conveyor, tasks.size());
    List futures = executorService.invokeAll(tasks);

    ConcurrentUtils.awaitFutures(futures);

    executorService.shutdown();
    executorService.awaitTermination(1L, TimeUnit.DAYS);

    conveyor.sync.acquire();

    conveyor.shutdown();

    for (Future future : futures)
    {
      future.get();
    }
  }