You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@commons.apache.org by st...@apache.org on 2018/02/15 01:54:59 UTC
[04/17] commons-rdf git commit: Use ForkJoinPool instead of own
ThreadPool
Use ForkJoinPool instead of own ThreadPool
Project: http://git-wip-us.apache.org/repos/asf/commons-rdf/repo
Commit: http://git-wip-us.apache.org/repos/asf/commons-rdf/commit/96c21ea5
Tree: http://git-wip-us.apache.org/repos/asf/commons-rdf/tree/96c21ea5
Diff: http://git-wip-us.apache.org/repos/asf/commons-rdf/diff/96c21ea5
Branch: refs/heads/fluent-parser
Commit: 96c21ea5d97b14011e9bceb19d16d7ccf4fe2732
Parents: 092c465
Author: Stian Soiland-Reyes <st...@apache.org>
Authored: Thu Feb 16 11:52:58 2017 +0000
Committer: Stian Soiland-Reyes <st...@apache.org>
Committed: Wed Feb 14 18:57:54 2018 +0000
----------------------------------------------------------------------
.../commons/rdf/simple/experimental/AbstractRDFParser.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/commons-rdf/blob/96c21ea5/commons-rdf-simple/src/main/java/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.java
----------------------------------------------------------------------
diff --git a/commons-rdf-simple/src/main/java/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.java b/commons-rdf-simple/src/main/java/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.java
index 0ef4d68..55c8de8 100644
--- a/commons-rdf-simple/src/main/java/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.java
+++ b/commons-rdf-simple/src/main/java/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.java
@@ -25,6 +25,7 @@ import java.nio.file.Path;
import java.util.Optional;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.function.Consumer;
@@ -58,9 +59,6 @@ import org.apache.commons.rdf.simple.SimpleRDF;
*/
public abstract class AbstractRDFParser<T extends AbstractRDFParser<T>> implements RDFParser, Cloneable {
- public static final ThreadGroup threadGroup = new ThreadGroup("Commons RDF parsers");
- private static final ExecutorService threadpool = Executors.newCachedThreadPool(r -> new Thread(threadGroup, r));
-
// Basically only used for creating IRIs
private static RDF internalRdfTermFactory = new SimpleRDF();
@@ -213,6 +211,7 @@ public abstract class AbstractRDFParser<T extends AbstractRDFParser<T>> implemen
private Consumer<Quad> target;
private Dataset targetDataset;
private Graph targetGraph;
+ private ExecutorService threadpool = ForkJoinPool.commonPool();
@SuppressWarnings("unchecked")
@Override
@@ -531,6 +530,7 @@ public abstract class AbstractRDFParser<T extends AbstractRDFParser<T>> implemen
@Override
public Future<ParseResult> parse() throws IOException, IllegalStateException {
final AbstractRDFParser<T> c = prepareForParsing();
+
return threadpool.submit(() -> {
c.parseSynchronusly();
return null;