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

Class AsyncProcessingPipelineSegmentGroup

java.lang.Object

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

All Implemented Interfaces:

IAsyncProcessingPipelineSegmentGroup

public class AsyncProcessingPipelineSegmentGroup
extends Object
implements IAsyncProcessingPipelineSegmentGroup

The group of segments which have the same priority and execution strategy (exclusive/parallel)

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addSegment(IAsyncProcessingPipelineSegment segment)	Adds a new segment to the group.
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
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 externalGroup)	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	remove(String segmentId, Object objectId)	Removes object from a specified segment 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

getRunningExclusiveTasks, getRunningHalfExclusiveTasks

Constructor Details

AsyncProcessingPipelineSegmentGroup

public AsyncProcessingPipelineSegmentGroup(DerivedDataSegmentBucket stage)

Creates an instance of the DD async. pipeline segment group.

Parameters:

stage - The target DD pipeline bucket. May not be null

Method Details

addSegment

public void addSegment(IAsyncProcessingPipelineSegment segment)

Adds a new segment to the group.

Parameters:

segment - The pipeline segment to add.

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)

Gathers next available task.

Specified by:

gatherNextAvailableTask in interface IAsyncProcessingPipelineSegmentGroup

Returns:

The next available task if any.

getGroupMultiThreadingComputePolicy

public MultithreadingComputationPolicy getGroupMultiThreadingComputePolicy()

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

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()

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()

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

remove

public void remove(String segmentId,
 Object objectId)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Removes object from a specified segment of this group (if any).

Specified by:

remove in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

segmentId - The target DD segment identifier. 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

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

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 externalGroup)

Description copied from interface: IAsyncProcessingPipelineSegmentGroup

Merges the modal operation group back to the main pipeline group

Specified by:

merge in interface IAsyncProcessingPipelineSegmentGroup

Parameters:

externalGroup - 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