org.apache.reef.wake.impl

Class WakeSharedPool

java.lang.Object

org.apache.reef.wake.impl.WakeSharedPool

All Implemented Interfaces:

AutoCloseable, Stage

public class WakeSharedPool
extends Object
implements Stage

Constructor Summary

Constructors

Constructor and Description
WakeSharedPool()
WakeSharedPool(int parallelism)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	submit(ForkJoinTask<?> t)

Methods inherited from class java.lang.Object

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

Constructor Detail

WakeSharedPool

@Inject
public WakeSharedPool(int parallelism)

WakeSharedPool

@Inject
public WakeSharedPool()

Method Detail

submit

public void submit(ForkJoinTask<?> t)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception