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

Class TestSupplier

java.lang.Object

com._1c.g5.v8.internal.derived.scheduler.TestSupplier

All Implemented Interfaces:

IDerivedDataTaskSupplier

public class TestSupplier
extends Object
implements IDerivedDataTaskSupplier

Test supplier implementation

Nested Class Summary

Nested classes/interfaces inherited from interface com._1c.g5.v8.internal.derived.scheduler.IDerivedDataTaskSupplier

IDerivedDataTaskSupplier.MultithreadingPolicy, IDerivedDataTaskSupplier.TaskStatus

Constructor Summary

Constructors

Constructor	Description
TestSupplier()

Method Summary

Modifier and Type	Method	Description
void	addFirst(DerivedDataComputationTask task)
void	addFirst(DerivedDataComputationTask task, DerivedDataSegmentBucket stage)
void	addLast(DerivedDataComputationTask task)
void	addLast(DerivedDataComputationTask task, DerivedDataSegmentBucket stage)
boolean	checkStatusChange()	Checks if the supplier has a status change since the last call of this method.
void	dropTasks()
DerivedDataSegmentBucket	getActiveNonPriorityTasksResetRequiredStage()	Checks if a supplier requests a reset of currently computed non-priority tasks (e.g. due to more prioritable operation is appeared)
IDerivedDataTaskSupplier.TaskStatus	getAvailableTaskStatus()	Gets the information on the next available task (if any).
IDerivedDataTaskSupplier.MultithreadingPolicy	getMultithreadingPolicy()	Gets the current desired multithreading policy for current set of tasks of this supplier.
DerivedDataComputationTask	getNextTask()	Gets the next task for the processing.
String	getSupplierId()	Gets the supplier id for easier discrimination by the scheduling facility.
ITaskProcessor	getTaskProcessor(DerivedDataComputationTask computationTask)	Gets the processing logic for the given task.
void	processAccumulatedContexts()	Processes accumulated DD contexts and update the DD pipeline.
void	registerNotificationCallback(ISchedulerNotificationCallback notificationCallback)	DerivedDataTaskScheduler registers a notification callback on start by calling this method.
void	setBlocked(boolean blocked)
void	setChanged(Boolean changed)
void	setTaskProcessor(ITaskProcessor taskProcessor)
void	tryToUnblock()	Tries to unblock the supplier, if blocked

Methods inherited from class java.lang.Object

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

Constructor Details

TestSupplier

public TestSupplier()

Method Details

addFirst

public void addFirst(DerivedDataComputationTask task)

addLast

public void addLast(DerivedDataComputationTask task)

addFirst

public void addFirst(DerivedDataComputationTask task,
 DerivedDataSegmentBucket stage)

addLast

public void addLast(DerivedDataComputationTask task,
 DerivedDataSegmentBucket stage)

dropTasks

public void dropTasks()

getAvailableTaskStatus

public IDerivedDataTaskSupplier.TaskStatus getAvailableTaskStatus()

Description copied from interface: IDerivedDataTaskSupplier

Gets the information on the next available task (if any).

Specified by:

getAvailableTaskStatus in interface IDerivedDataTaskSupplier

Returns:

The task status for a next available task. Never null

getMultithreadingPolicy

public IDerivedDataTaskSupplier.MultithreadingPolicy getMultithreadingPolicy()

Description copied from interface: IDerivedDataTaskSupplier

Gets the current desired multithreading policy for current set of tasks of this supplier.

Specified by:

getMultithreadingPolicy in interface IDerivedDataTaskSupplier

Returns:

Gets the current policy. Cannot be null

getNextTask

public DerivedDataComputationTask getNextTask()

Description copied from interface: IDerivedDataTaskSupplier

Gets the next task for the processing. It's not required(yet recommended) for implementations to ensure the integrity of the task info request and task request. So it's possible for the task to disappear or change the priority during the call of the IDerivedDataTaskSupplier.getAvailableTaskStatus() and subsequent call of this method

Specified by:

getNextTask in interface IDerivedDataTaskSupplier

Returns:

The next task if available. Can be null in case if the state was changed since the last call of the IDerivedDataTaskSupplier.getAvailableTaskStatus()

getTaskProcessor

public ITaskProcessor getTaskProcessor(DerivedDataComputationTask computationTask)

Description copied from interface: IDerivedDataTaskSupplier

Gets the processing logic for the given task. It's up to this logic to perform any processing/notifications during the DD computation process

Specified by:

getTaskProcessor in interface IDerivedDataTaskSupplier

Parameters:

computationTask - The computation task, cannot be null

Returns:

The ITaskProcessor which is able to perform the DD computation for this task. Cannot be null

registerNotificationCallback

public void registerNotificationCallback(ISchedulerNotificationCallback notificationCallback)

Description copied from interface: IDerivedDataTaskSupplier

DerivedDataTaskScheduler registers a notification callback on start by calling this method. The provided callback should be used to notify scheduler about the availability of a new task. This API is used to increase the operativeness of the DD computations during the normal interractions with the EDT. Provided callback is fully controlled by the dispatcher, the clinet shouldn't pay any specific attention to its lifecycle

Specified by:

registerNotificationCallback in interface IDerivedDataTaskSupplier

Parameters:

notificationCallback - The callback from the DerivedDataTaskScheduler, cannot be null

setTaskProcessor

public void setTaskProcessor(ITaskProcessor taskProcessor)

getSupplierId

public String getSupplierId()

Description copied from interface: IDerivedDataTaskSupplier

Gets the supplier id for easier discrimination by the scheduling facility. The identifier should be unique in the current session of the EDT

Specified by:

getSupplierId in interface IDerivedDataTaskSupplier

Returns:

The supplier identifier. Cannot be null

processAccumulatedContexts

public void processAccumulatedContexts()

Description copied from interface: IDerivedDataTaskSupplier

Processes accumulated DD contexts and update the DD pipeline. This method is not thread safe, the caller should guarantee the calls synchronization to ensure the propert order of accumulated context application

Specified by:

processAccumulatedContexts in interface IDerivedDataTaskSupplier

checkStatusChange

public boolean checkStatusChange()

Description copied from interface: IDerivedDataTaskSupplier

Checks if the supplier has a status change since the last call of this method. The call should reset the change status of the supplier.\n The status change is used to re-check blocked suppliers, as they could be unblocked as a result of this status change

Specified by:

checkStatusChange in interface IDerivedDataTaskSupplier

Returns:

True if there is a status change since the last call of this method

setChanged

public void setChanged(Boolean changed)

setBlocked

public void setBlocked(boolean blocked)

tryToUnblock

public void tryToUnblock()

Description copied from interface: IDerivedDataTaskSupplier

Tries to unblock the supplier, if blocked

Specified by:

tryToUnblock in interface IDerivedDataTaskSupplier

getActiveNonPriorityTasksResetRequiredStage

public DerivedDataSegmentBucket getActiveNonPriorityTasksResetRequiredStage()

Description copied from interface: IDerivedDataTaskSupplier

Checks if a supplier requests a reset of currently computed non-priority tasks (e.g. due to more prioritable operation is appeared)

Specified by:

getActiveNonPriorityTasksResetRequiredStage in interface IDerivedDataTaskSupplier

Returns:

Stage to reset non-priority tasks (if any). null if not reset is required