static L<Web> websMadeByProgram_parallel(S progID) {
  ret websMadeByProgram_parallel(progID, null);
}

static L<Web> websMadeByProgram_parallel(S progID, final Map<Web, SoftwareMadeWeb> furtherInfoMap) ctex {
  // TODO: clean up file handle in case of error
  IterableIterator<S> l = scanLog_iterator(progID, "webs-made.txt");
  fS src = progID;
  final new L<Pair<Web, Int>> webs;
  
  int poolSize = numberOfCores(), queueSize = 20;
  NotifyingBlockingThreadPoolExecutor e = new(poolSize, queueSize, 15, TimeUnit.SECONDS);
  
  try {
    int i = 0;
    for (fS s : l) {
      ++i;
      final int _i = i;
      e.execute(r { pcall {
        SoftwareMadeWeb o = cast unstructure(s);
        Web web = o.web;
        if (web == null)
          web = (Web) unstructure(o.structure);
        if (web != null) synchronized(webs) {
          webs.add(pair(web_intern(web_setSourceIfEmpty(web, src)), _i));
          mapPut(furtherInfoMap, web, o);
        }
      }});
    }
    //e.await(); // ConcurrentModificationException sometimes??
    e.shutdown();
    e.awaitTermination(1, TimeUnit.DAYS);
  } finally {
    e.shutdown();
  }
  
  time "Sort" {
    sortBySecondOfPairs_inPlace(webs);
  }
  
  ret concatLists(ai_triplesMadeByProgram(progID), firstOfPairs(webs));
}