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

Class DerivedDataTaskScheduler

java.lang.Object

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

public class DerivedDataTaskScheduler
extends Object

Task scheduler is responsible for requesting tasks from the provided sources and dispatching them into the execution pool.
Each source represents the DD task pipeline of some EDT project being run at the moment.
The task scheduler performs a single task scheduling per scheduling step. Scheduling steps are being performed as the part of the scheduling cycle.
The scheduling cycle should be called in a separate thread by using jobs or other means of asycnrhonous execution. The schedulong cycle should be active while at least one EDT project exists and active

Constructor Summary

Constructors

Constructor	Description
DerivedDataTaskScheduler(IDerivedDataExecutorPool pool, ISystemIdleService systemIdleService)

Method Summary

Modifier and Type	Method	Description
void	activate()
void	addSupplier(IDerivedDataTaskSupplier supplier)
void	deactivate()	Deactivates the scheduler
void	notifyScheduler()	Notifies scheduler that there is a client that needs DD data processing (e.g. processing of accumulated contexts, etc) This method is used to wake the scheduler earlier on its scheduling cycle
void	removeSupplier(IDerivedDataTaskSupplier supplier)	Removes the given supplier from the scheduler registry
void	scheduleNonPriorityTaskCancelling()

Methods inherited from class java.lang.Object

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

Constructor Details

DerivedDataTaskScheduler

public DerivedDataTaskScheduler(IDerivedDataExecutorPool pool,
 ISystemIdleService systemIdleService)

Method Details

activate

public void activate()

addSupplier

public void addSupplier(IDerivedDataTaskSupplier supplier)

deactivate

public void deactivate()

Deactivates the scheduler

removeSupplier

public void removeSupplier(IDerivedDataTaskSupplier supplier)

Removes the given supplier from the scheduler registry

Parameters:

supplier - The supplier. May not be null

scheduleNonPriorityTaskCancelling

public void scheduleNonPriorityTaskCancelling()

notifyScheduler

public void notifyScheduler()

Notifies scheduler that there is a client that needs DD data processing (e.g. processing of accumulated contexts, etc) This method is used to wake the scheduler earlier on its scheduling cycle