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

Class WorkerManager

java.lang.Object

com._1c.g5.v8.internal.derived.WorkerManager

public class WorkerManager
extends Object

Component that provides DD workers for the task that being dispatched by the DD scheduler. In addition to the worker management, this component also tracks DD computations errors and allows computation retries by postponed confirmation of the failure

See Also:

• IComputationTaskManager
• IDerivedDataComputer

Constructor Summary

Constructors

Constructor	Description
WorkerManager(IComputationTaskManager taskManager, IDerivedDataContextManager contextManager, IContextTransactionManager contextTransactionManager, IAsyncProcessingPipeline asyncProcessingPipeline, Collection<IDerivedDataComputer> computers, Set<String> filteredSegments)	Construct a new instance, performs basic initialization.

Method Summary

Modifier and Type	Method	Description
ITaskProcessor	createWorker(DerivedDataComputationTask task)	Creates the worker logic for the given task object
void	start(IBmModel bmModel)

Methods inherited from class java.lang.Object

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

Constructor Details

WorkerManager

public WorkerManager(IComputationTaskManager taskManager,
 IDerivedDataContextManager contextManager,
 IContextTransactionManager contextTransactionManager,
 IAsyncProcessingPipeline asyncProcessingPipeline,
 Collection<IDerivedDataComputer> computers,
 Set<String> filteredSegments)

Construct a new instance, performs basic initialization.

Parameters:

taskManager - the task manager to receive tasks from, cannot be null

contextManager - the DD context manager to get contexts from, cannot be null

contextTransactionManager - the DD context transaction manager to manipulate context sessions, cannot be null

asyncProcessingPipeline - the DD pipeline, cannot be null

computers - the computers to delegate computations to, cannot be null

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

bmModel - the instance of the BM model, cannot be null

Method Details

start

public void start(IBmModel bmModel)

createWorker

public ITaskProcessor createWorker(DerivedDataComputationTask task)

Creates the worker logic for the given task object

Parameters:

task - The task to create worker logic for

Returns:

The Callable with the processing logic. Cannot be null