Importer spawns as many threads as processors
@@ -248,7 +248,7 @@ public class JanusGraphImporter implements DBgenImporter {
tasks.add(new VertexLoadingTask(graph,schema,dir+"/"+fileName,vertexLabel,TRANSACTIONSIZE));
}
}
- ThreadPool threadPool = new ThreadPool(4,tasks.size());
+ ThreadPool threadPool = new ThreadPool(Runtime.getRuntime().availableProcessors(),tasks.size());
for(VertexLoadingTask task : tasks) {
try {
threadPool.execute(task);
