org.apache.ignite.ml.environment.parallelism

Class DefaultParallelismStrategy

java.lang.Object

org.apache.ignite.ml.environment.parallelism.DefaultParallelismStrategy

All Implemented Interfaces:

ParallelismStrategy

public class DefaultParallelismStrategy
extends Object
implements ParallelismStrategy

All task should be processed by default thread pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultParallelismStrategy.FutureWrapper<T> Wrapper for future class.

Nested classes/interfaces inherited from interface org.apache.ignite.ml.environment.parallelism.ParallelismStrategy

ParallelismStrategy.Type

Constructor Summary

Constructors

Constructor and Description
DefaultParallelismStrategy()

Method Summary

Modifier and Type	Method and Description
<T> Promise<T>	submit(IgniteSupplier<T> task) Submit task.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.ml.environment.parallelism.ParallelismStrategy

submit

Constructor Detail

DefaultParallelismStrategy

public DefaultParallelismStrategy()

Method Detail

submit

public <T> Promise<T> submit(IgniteSupplier<T> task)

Submit task.

Specified by:

submit in interface ParallelismStrategy

Parameters:

task - Task.