public static <T> Distributor<T> createWithCapacity(int capacity) {
    return new Distributor<>(capacity);
  }
Returns a new {@code Distributor} that can hold up to {@code capacity} pending elements.
planetiler-core/src/main/java/com/onthegomap/planetiler/worker/Distributor.java