This is an automated email from the ASF dual-hosted git repository. andy pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/jena.git
commit 3a006c4a6b44c0fe3af22e619937fb03c6f2c5f2 Author: Andy Seaborne <[email protected]> AuthorDate: Sun Nov 23 21:13:42 2025 +0000 Add ExecutionContext.checkCancelSignal --- .../main/java/org/apache/jena/sparql/engine/ExecutionContext.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/jena-arq/src/main/java/org/apache/jena/sparql/engine/ExecutionContext.java b/jena-arq/src/main/java/org/apache/jena/sparql/engine/ExecutionContext.java index a1b87415f8..7a0ddbba9b 100644 --- a/jena-arq/src/main/java/org/apache/jena/sparql/engine/ExecutionContext.java +++ b/jena-arq/src/main/java/org/apache/jena/sparql/engine/ExecutionContext.java @@ -27,6 +27,7 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.jena.atlas.iterator.Iter; import org.apache.jena.graph.Graph; import org.apache.jena.query.ARQ; +import org.apache.jena.query.QueryCancelledException; import org.apache.jena.sparql.core.DatasetGraph; import org.apache.jena.sparql.core.DatasetGraphFactory; import org.apache.jena.sparql.engine.main.OpExecutorFactory; @@ -183,6 +184,12 @@ public class ExecutionContext implements FunctionEnv return cancelSignal; } + /** Check the cancel signal and throw {@link QueryCancelledException}} if it is true. */ + public void checkCancelSignal() { + if ( cancelSignal != null && cancelSignal.get() ) + throw new QueryCancelledException(); + } + public void openIterator(QueryIterator qIter) { openIterators.add(qIter); if ( allIterators != null )
