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 inherited from interface io.deephaven.engine.updategraph.OperationInitializer

NON_PARALLELIZABLE

Constructor Summary

Constructors

Constructor	Description
OperationInitializationThreadPool(ThreadInitializationFactory factory)
OperationInitializationThreadPool(ThreadInitializationFactory factory, int numThreads)

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.
void	shutdown()
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

Constructor Details

OperationInitializationThreadPool

public OperationInitializationThreadPool(ThreadInitializationFactory factory)

OperationInitializationThreadPool

public OperationInitializationThreadPool(ThreadInitializationFactory factory,
 int numThreads)

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

shutdown

public void shutdown()