Package com._1c.g5.v8.internal.derived.pipeline

Class OperationPipelineSegmentGroup

java.lang.Object

com._1c.g5.v8.internal.derived.pipeline.OperationPipelineSegmentGroup

All Implemented Interfaces:

IAsyncProcessingPipelineSegmentGroup

public class OperationPipelineSegmentGroup
extends Object
implements IAsyncProcessingPipelineSegmentGroup

The operation-specific implementation of the IAsyncProcessingPipelineSegmentGroup

Constructor Summary

Constructors

Constructor	Description
OperationPipelineSegmentGroup(IAsyncProcessingPipelineSegment segment, DerivedDataSegmentBucket stage)	Creates an instance of the DD async. pipeline segment group.

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the group completelly
boolean	confirmTaskCompletion(Object objectId)	Confirms completion of a task from the current group.
void	deactivateContexts(String segmentId)	Deactivates scheduled contexts in the pipeline group for a specified segment
Pair<String,Object>	gatherNextAvailableTask(Collection<AllowedComputations> allowedComputations)	Gathers next available task.
MultithreadingComputationPolicy	getGroupMultiThreadingComputePolicy()	Gets the group multithreading policy.
Map<Object,String>	getLocks()	Gets the set of current locks in the pipeline
OperationContext	getModalOperationContext()	Gets the active modal operation context in this group if any
Collection<String>	getRegisteredSegmentIds()	Gets an ordered list of registered segment ids for this group.
OperationType	getRunningExclusiveOperationType()	Gets the type of the exclusive operation being run in the current group
Map<Object,String>	getRunningExclusiveTasks()	Gets running exclusive tasks if any
Set<Object>	getRunningHalfExclusiveTasks()	Gets the set of running half-exclusive tasks
IAsyncProcessingPipelineSegment	getSegment(String segmentId)	Gets the pipeline segment from the group
DerivedDataSegmentBucket	getStage()	Gets a DD pipeline stage this group is belongs to
boolean	hasAvaiableTasks(Collection<AllowedComputations> allowedComputations)	Checks if the group has available tasks.
boolean	hasPriorityTasks()	Checks if this group has priority tasks to compute
boolean	hasRunningImportantTasks()	Checks if this group has any of important tasks being run at the moment
boolean	hasScheduledContexts()	Checks if the given group has any scheduled contexts,
boolean	hasUnfinishedBlockingTasks()	Checks if the current group has active tasks being run at the moment.
void	increasePriority(String segmentId)	Increase the priority of the segment.
void	increasePriority(String segmentId, Object objectId)	Increases priority of a specific object DD segment.
void	merge(IAsyncProcessingPipelineSegmentGroup group)	Merges the modal operation group back to the main pipeline group
void	remove(Object objectId)	Removes object from all segments of this group (if any).
void	schedule(String segmentId, Object objectId)	Schedules the context into the group.
void	scheduleOperation(OperationContext operationContext)	Schedules the orchestrated operation
void	unlockTask(Object objectId)	Unocks the task allowing the DD to compute it

Methods inherited from class java.lang.Object

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

Methods inherited from interface com._1c.g5.v8.internal.derived.pipeline.IAsyncProcessingPipelineSegmentGroup

remove

Constructor Details

OperationPipelineSegmentGroup

public OperationPipelineSegmentGroup(IAsyncProcessingPipelineSegment segment,
 DerivedDataSegmentBucket stage)

Creates an instance of the DD async. pipeline segment group. Contains only one segment.

Parameters:

segment - The target operation segment. May not be null

stage - The target pipeline stage. May not be null

Method Details

confirmTaskCompletion

public boolean confirmTaskCompletion(Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Confirms completion of a task from the current group. As it's impossible to compute same object contexts for different segments simultaneously in a single group, the segment definition is not required.

Specified by:

confirmTaskCompletion in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True of the task was confirmed successfully. False in case if the task was absent in the target pipeline

gatherNextAvailableTask

public Pair<String,Object> gatherNextAvailableTask(Collection<AllowedComputations> allowedComputations)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gathers next available task.

Specified by:

gatherNextAvailableTask in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The next available task if any.

getGroupMultiThreadingComputePolicy

public MultithreadingComputationPolicy getGroupMultiThreadingComputePolicy()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the group multithreading policy. The group always has single policy. In case if grouped segments has different policies, the group selects highest one.

Specified by:

getGroupMultiThreadingComputePolicy in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The combined multithreading computation policy of the group.

getLocks

public Map<Object,String> getLocks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the set of current locks in the pipeline

Specified by:

getLocks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The set of current locks. May not be null

getRegisteredSegmentIds

public Collection<String> getRegisteredSegmentIds()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets an ordered list of registered segment ids for this group.

Specified by:

getRegisteredSegmentIds in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The list of segment ids for async. DD pipeline segments belonging to this group.

getRunningExclusiveOperationType

public OperationType getRunningExclusiveOperationType()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the type of the exclusive operation being run in the current group

Specified by:

getRunningExclusiveOperationType in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The running exclusive operation type, if any. null otherwise

getRunningExclusiveTasks

public Map<Object,String> getRunningExclusiveTasks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets running exclusive tasks if any

Specified by:

getRunningExclusiveTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The map of running exclusive tasks, never null

getRunningHalfExclusiveTasks

public Set<Object> getRunningHalfExclusiveTasks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the set of running half-exclusive tasks

Specified by:

getRunningHalfExclusiveTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The set of tasks, never null

getSegment

public IAsyncProcessingPipelineSegment getSegment(String segmentId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the pipeline segment from the group

Specified by:

getSegment in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The identifier of the segment

Returns:

The segment, if presents. Could be null

hasAvaiableTasks

public boolean hasAvaiableTasks(Collection<AllowedComputations> allowedComputations)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Checks if the group has available tasks. Tasks are available in case if there are scheduled context(s) in at least one segment, and those contexts aren't blocked by currently computed DD segments (block based on the top object).

Specified by:

hasAvaiableTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True if the next task is available; false otherwise.

hasPriorityTasks

public boolean hasPriorityTasks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Checks if this group has priority tasks to compute

Specified by:

hasPriorityTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True if the group has priority tasks to compute

hasScheduledContexts

public boolean hasScheduledContexts()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Checks if the given group has any scheduled contexts,

Specified by:

hasScheduledContexts in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True if any of group segments contains scheduled tasks; false otherwise.

hasUnfinishedBlockingTasks

public boolean hasUnfinishedBlockingTasks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Checks if the current group has active tasks being run at the moment.

Specified by:

hasUnfinishedBlockingTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True in case if there are unfinished tasks belonging to this group being computed by DD subsystem.

hasRunningImportantTasks

public boolean hasRunningImportantTasks()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Checks if this group has any of important tasks being run at the moment

Specified by:

hasRunningImportantTasks in interface IAsyncProcessingPipelineSegmentGroup

Returns:

True if the group has any of important tasks being run at the moment

increasePriority

public void increasePriority(String segmentId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Increase the priority of the segment.

Specified by:

increasePriority in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The DD segement to increase the priority for. Cannot be null

increasePriority

public void increasePriority(String segmentId,
 Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Increases priority of a specific object DD segment. Allows async. DD facility to compute this DD segment as soon as possible.

Specified by:

increasePriority in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The identifier of the DD segment.

objectId - The identifier of the object.

remove

public void remove(Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Removes object from all segments of this group (if any).

Specified by:

remove in interface IAsyncProcessingPipelineSegmentGroup

schedule

public void schedule(String segmentId,
 Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Schedules the context into the group.

Specified by:

schedule in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The target DD segment identifier. May not be null

objectId - The target object identifier. Must be either Long or String. May not be null

deactivateContexts

public void deactivateContexts(String segmentId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Deactivates scheduled contexts in the pipeline group for a specified segment

Specified by:

deactivateContexts in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The segment to deactivate scheduled contexts for. Cannot be null

scheduleOperation

public void scheduleOperation(OperationContext operationContext)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Schedules the orchestrated operation

Specified by:

scheduleOperation in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

operationContext - The context of the operation to schedule. May not be null

unlockTask

public void unlockTask(Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Unocks the task allowing the DD to compute it

Specified by:

unlockTask in interface IAsyncProcessingPipelineSegmentGroup

getModalOperationContext

public OperationContext getModalOperationContext()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets the active modal operation context in this group if any

Specified by:

getModalOperationContext in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The active modal operation context if any. null otherwise

merge

public void merge(IAsyncProcessingPipelineSegmentGroup group)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Merges the modal operation group back to the main pipeline group

Specified by:

merge in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

group - The modal pipeline group to merge. May not be null

clear

public void clear()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Clears the group completelly

Specified by:

clear in interface IAsyncProcessingPipelineSegmentGroup

getStage

public DerivedDataSegmentBucket getStage()

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Gets a DD pipeline stage this group is belongs to

Specified by:

getStage in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The DD pipeline stage of the group. May not be null