please include function webs_readTripleFileAsTriples.

static L<TripleWeb> webs_readTripleFileAsTriples_parallel2(File f) ctex {
  if (!f.exists()) ret ll();
  time "Getting names" {
    Iterator<S> it = linesFromFile(f);
    final new L<Symbol> names;
    while (it.hasNext()) {
      S s = trim(it.next());
      if (empty(s)) break;
      names.add(symbol(unquote(s)));
    }
  }
  
  if (webs_readTripleFileAsTriples_debug)
    print("Have " + l(names) + " names");
  
  final L<Pair<L<TripleWeb>, Int>> triples = new L;
  
  int poolSize = numberOfCores(), queueSize = 10000;
  int blockSize = 1000;
  NotifyingBlockingThreadPoolExecutor e = new(poolSize, queueSize, 15, TimeUnit.SECONDS);
  print("Using " + poolSize + " cores, block size: " + blockSize + ".");
  
  try {
    int i = 0;
    L<S> block = emptyListWithCapacity(blockSize);
    while licensed {
      ++i;
      final Int _i = i;
      bool hasNext = it.hasNext();
      if ((!hasNext || l(block) >= blockSize) && nempty(block)) {
        final L<S> _block = cloneList(block);
        e.execute(r { pcall {
          L<TripleWeb> l = emptyListWithCapacity(_block);
          for (S s : _block) {
            TripleWeb w = webs_readTripleFileAsTriples_line(s, names);
            if (w != null)
              l.add(w);
          }
          synchronized(triples) {
            triples.add(pair(l, _i));
          }
        }});
        block.clear();
      }
      if (hasNext)
        block.add(it.next());
      else
        break;
    }
    e.shutdown();
    e.awaitTermination(1, TimeUnit.DAYS);
  } finally {
    e.shutdown();
  }
  
  sortBySecondOfPairs_inPlace(triples);
  int n = 0;
  for (Pair<L<TripleWeb>, Int> p : triples)
    n += l(p.a);
  L<TripleWeb> l = emptyListWithCapacity(n);
  for (Pair<L<TripleWeb>, Int> p : triples)
    l.addAll(p.a);
  ret l;
}

Began life as a copy of #1012453