Package io.deephaven.engine.table.impl

Class OperationInitializationThreadPool

java.lang.Object

io.deephaven.engine.table.impl.OperationInitializationThreadPool

All Implemented Interfaces:

OperationInitializer

public class OperationInitializationThreadPool
extends Object
implements OperationInitializer

Implementation of OperationInitializer that delegates to a pool of threads.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NUM_THREADS	The number of threads that will be used for parallel initialization in this process

Fields inherited from interface io.deephaven.engine.updategraph.OperationInitializer

NON_PARALLELIZABLE

Constructor Summary

Constructors

Constructor	Description
OperationInitializationThreadPool(ThreadInitializationFactory factory)

Method Summary

Modifier and Type	Method	Description
boolean	canParallelize()	Whether the current thread can parallelize operations using this OperationInitialization.
int	parallelismFactor()	Number of threads that are potentially available.
Future<?>	submit(Runnable runnable)	Submits a task to run in this thread pool.

Methods inherited from class java.lang.Object

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

Field Details

NUM_THREADS

public static final int NUM_THREADS

The number of threads that will be used for parallel initialization in this process

Constructor Details

OperationInitializationThreadPool

public OperationInitializationThreadPool(ThreadInitializationFactory factory)

Method Details

canParallelize

public boolean canParallelize()

Description copied from interface: OperationInitializer

Whether the current thread can parallelize operations using this OperationInitialization.

Specified by:

canParallelize in interface OperationInitializer

submit

public Future<?> submit(Runnable runnable)

Description copied from interface: OperationInitializer

Submits a task to run in this thread pool.

Specified by:

submit in interface OperationInitializer

parallelismFactor

public int parallelismFactor()

Description copied from interface: OperationInitializer

Number of threads that are potentially available.

Specified by:

parallelismFactor in interface OperationInitializer