@Override
      public void close() {
        finish();
        drain();
      }
A handle for each worker thread to offer new items, and drain the remaining ones when done.
planetiler-core/src/main/java/com/onthegomap/planetiler/worker/Distributor.java