com.saxonica.ee.optim

Class MultithreadedForEach

java.lang.Object

net.sf.saxon.expr.Expression

net.sf.saxon.expr.instruct.Instruction

net.sf.saxon.expr.instruct.ForEach

com.saxonica.ee.optim.MultithreadedForEach

All Implemented Interfaces:

SourceLocator, ContextMappingFunction, ContextSwitchingExpression, TailCallReturner, IdentityComparable, InstructionInfo

public class MultithreadedForEach
extends ForEach

This instruction represents an xsl:for-each instruction using more than one thread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MultithreadedForEach.MyRejectedExecutionHandelerImpl Handles exceptions thrown in the thread pool manager

Field Summary

Fields inherited from class net.sf.saxon.expr.instruct.ForEach

action, containsTailCall, select, threads

Fields inherited from class net.sf.saxon.expr.Expression

EFFECTIVE_BOOLEAN_VALUE, EVALUATE_METHOD, ITEM_FEED_METHOD, ITERATE_METHOD, locationId, MAX_SEQUENCE_LENGTH, MAX_STRING_LENGTH, PROCESS_METHOD, staticProperties, UNBOUNDED_LOWER, UNBOUNDED_UPPER, WATCH_METHOD

Constructor Summary

Constructors

Constructor and Description
MultithreadedForEach(Expression select, Expression action, boolean containsTailCall, Expression threads)

Method Summary

Methods

Modifier and Type	Method and Description
Expression	copy() Copy an expression.
protected void	explainThreads(ExpressionPresenter out) Add the value of the saxon:threads attribute to the explain output
ExpressionCompiler	getExpressionCompiler() Return the compiler of the MultithreadedForEach expression
int	getImplementationMethod() An implementation of Expression must provide at least one of the methods evaluateItem(), iterate(), or process().
SequenceIterator	iterate(XPathContext context) Return an Iterator to iterate over the values of the sequence.
TailCall	processLeavingTail(XPathContext context) ProcessLeavingTail: called to do the real work of this instruction.
void	shutdown()

Methods inherited from class net.sf.saxon.expr.instruct.ForEach

addToPathMap, checkPermittedContents, computeDependencies, computeSpecialProperties, createsNewNodes, explain, getActionExpression, getExpressionName, getInstructionNameCode, getItemType, getNumberOfThreadsExpression, getSelectExpression, getStreamingAdjunct, map, operands, optimize, promoteInst, replaceOperand, setActionExpression, setSelectExpression, toShortString, toString, typeCheck, unordered

Methods inherited from class net.sf.saxon.expr.instruct.Instruction

assembleParams, assembleTunnelParams, computeCardinality, dynamicError, evaluateAsString, evaluateItem, getConstructType, getInstructionName, getIteratorFromProcessMethod, getSourceLocator, isXSLT, process, promote, toStreamingPattern

Methods inherited from class net.sf.saxon.expr.Expression

adoptChildExpression, checkForUpdatingSubexpressions, clearStreamabilityData, computeStaticProperties, doPromotion, dynamicError, effectiveBooleanValue, evaluatePendingUpdates, explain, getCardinality, getColumnNumber, getConfiguration, getContainer, getDependencies, getEvaluationMethod, getHostLanguage, getIntegerBounds, getIntrinsicDependencies, getLineNumber, getLocationId, getObjectName, getPosture, getProperties, getProperty, getPublicId, getSlotsUsed, getSpecialProperties, getStreamability, getSweep, getSystemId, hasVariableBinding, identityHashCode, implementsStaticTypeCheck, isIdentical, isSubtreeExpression, isUpdatingExpression, isVacuousExpression, iterateEvents, makeStreamingAdjunct, markTailFunctionCalls, operandList, resetLocalStaticProperties, setContainer, setEvaluationMethod, setFiltered, setFlattened, setLocationId, setPostureAndSweep, simplify, staticTypeCheck, suppressValidation, toPattern, typeError

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.xml.transform.SourceLocator

getColumnNumber, getLineNumber, getPublicId, getSystemId

Constructor Detail

MultithreadedForEach

public MultithreadedForEach(Expression select,
                    Expression action,
                    boolean containsTailCall,
                    Expression threads)

Method Detail

copy

public Expression copy()

Copy an expression. This makes a deep copy.

Overrides:

copy in class ForEach

Returns:

the copy of the original expression

getImplementationMethod

public int getImplementationMethod()

An implementation of Expression must provide at least one of the methods evaluateItem(), iterate(), or process(). This method indicates which of these methods is provided. This implementation provides only the process() method natively.

Overrides:

getImplementationMethod in class ForEach

Returns:

the implementation method, for example Expression.ITERATE_METHOD or Expression.EVALUATE_METHOD or Expression.PROCESS_METHOD

processLeavingTail

public TailCall processLeavingTail(XPathContext context)
                            throws XPathException

Description copied from class: Instruction

ProcessLeavingTail: called to do the real work of this instruction. This method must be implemented in each subclass. The results of the instruction are written to the current Receiver, which can be obtained via the Controller.

Specified by:

processLeavingTail in interface TailCallReturner

Overrides:

processLeavingTail in class ForEach

Parameters:

context - The dynamic context of the transformation, giving access to the current node, the current variables, etc.

Returns:

null if the instruction has completed execution; or a TailCall indicating a function call or template call that is delegated to the caller, to be made after the stack has been unwound so as to save stack space.

Throws:

XPathException - if a dynamic error occurs during the evaluation of the instruction

iterate

public SequenceIterator iterate(XPathContext context)
                         throws XPathException

Return an Iterator to iterate over the values of the sequence.

Overrides:

iterate in class ForEach

Parameters:

context - supplies the context for evaluation

Returns:

a SequenceIterator that can be used to iterate over the result of the expression

Throws:

XPathException - if any dynamic error occurs evaluating the expression

shutdown

public void shutdown()

getExpressionCompiler

public ExpressionCompiler getExpressionCompiler()

Return the compiler of the MultithreadedForEach expression

Overrides:

getExpressionCompiler in class ForEach

Returns:

the relevant ExpressionCompiler

explainThreads

protected void explainThreads(ExpressionPresenter out)

Add the value of the saxon:threads attribute to the explain output

Overrides:

explainThreads in class ForEach

Parameters:

out - the destination for explain output