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

Class DerivedDataEngine

java.lang.Object

com._1c.g5.v8.internal.derived.DerivedDataEngine

All Implemented Interfaces:

IDerivedDataEngine

public final class DerivedDataEngine
extends Object
implements IDerivedDataEngine

Derived data engine implementation

Constructor Summary

Constructors

Constructor	Description
DerivedDataEngine(IUserActivityBlockingService userActivityBlockingService, ISystemIdleService systemIdleService)	Constructs an engine instance

Method Summary

Modifier and Type	Method	Description
IDerivedDataBmProvider	createProvider(String projectId, Collection<IDerivedDataConfigurationContributor> contributors, Set<String> filteredSegments, IDerivedDataServiceLockController lockController, Supplier<Boolean> synchronizationActiveStateSupplier, Supplier<IAsyncComputationExecutionContext> executionContextSupplier)	Creates a provider
void	setPermittedThreads(int permittedThreads)	Sets the maximum number of computation threads the DD subsystem should use at the moment.
void	start()	Starts the inactive engine.
void	stop()	Stops the active engine.

Methods inherited from class java.lang.Object

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

Constructor Details

DerivedDataEngine

public DerivedDataEngine(IUserActivityBlockingService userActivityBlockingService,
 ISystemIdleService systemIdleService)

Constructs an engine instance

Parameters:

userActivityBlockingService - The reference to the IUserActivityBlockingService service. May not be null

ISystemIdleService - The reference to the ISystemIdleService service. May not be null

Method Details

createProvider

public IDerivedDataBmProvider createProvider(String projectId,
 Collection<IDerivedDataConfigurationContributor> contributors,
 Set<String> filteredSegments,
 IDerivedDataServiceLockController lockController,
 Supplier<Boolean> synchronizationActiveStateSupplier,
 Supplier<IAsyncComputationExecutionContext> executionContextSupplier)

Description copied from interface: IDerivedDataEngine

Creates a provider

Specified by:

createProvider in interface IDerivedDataEngine

Parameters:

projectId - The unique identifier of the owner project. Cannot be null

contributors - The set of derived data contributors. Cannot be null. Can be empty

filteredSegments - The set of segment ids that should be ommitted during the computation. Cannot be null. Can be empty

lockController - The DD external lock controller. Cannot be null

synchronizationActiveStateSupplier - The supplier which provides the status of the synchronization. Cannot be null

executionContextSupplier - The supplier which provides client-specific IAsyncComputationExecutionContext. Cannot be null

Returns:

The created DD provider. Cannot be null

setPermittedThreads

public void setPermittedThreads(int permittedThreads)

Description copied from interface: IDerivedDataEngine

Sets the maximum number of computation threads the DD subsystem should use at the moment. It's up to client to control reduction/increasing the number of used threads, the DD subsystem itself won't adjust the maximum number of used threads (though could use less then maximum in any given moment)

Specified by:

setPermittedThreads in interface IDerivedDataEngine

Parameters:

permittedThreads - The number of permitted threads. Must be a positive number

start

public void start()

Description copied from interface: IDerivedDataEngine

Starts the inactive engine. The single engine instance mustn't be started more then once. The engine should be in inactive state prior the start call

Specified by:

start in interface IDerivedDataEngine

stop

public void stop()

Description copied from interface: IDerivedDataEngine

Stops the active engine. The single engine instance mustn't be stopped more then once. The engine should be in active state prior the stop call

Specified by:

stop in interface IDerivedDataEngine