|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgpars.scheduler.FJPool
public class FJPool
Represents the actors' thread pool, which performs tasks on behalf of the actors. Uses a ForkJoinPool from JSR-166y The actors' thread pool size defaults to the n + 1, where n is the number of processors/cores available on the machine. The VM parameter -Dgpars.poolsize can be used the configure the default size of the actors' thread pool. The resize() and resetDefaultSize() methods can be used to configure size of the thread pool at runtime.
Field Summary | |
---|---|
protected jsr166y.forkjoin.ForkJoinPool |
pool
|
Constructor Summary | |
FJPool()
Creates the pool with default number of threads. |
|
FJPool(int configuredPoolSize)
Creates the pool with specified number of threads. |
Method Summary | |
---|---|
void
|
execute(Runnable task)
schedules a new task for processing with the pool |
protected int
|
getConfiguredPoolSize()
|
jsr166y.forkjoin.ForkJoinPool
|
getForkJoinPool()
Retrieves the internal executor service. |
void
|
resetDefaultSize()
Sets the pool size to the default |
void
|
resize(int poolSize)
Resizes the thread pool to the specified value |
void
|
shutdown()
Gently stops the pool |
Methods inherited from class Object | |
---|---|
wait, wait, wait, equals, toString, hashCode, getClass, notify, notifyAll |
Field Detail |
---|
protected jsr166y.forkjoin.ForkJoinPool pool
Constructor Detail |
---|
public FJPool()
public FJPool(int configuredPoolSize)
configuredPoolSize
- The required size of the pool
Method Detail |
---|
public void execute(Runnable task)
task
- The task to schedule
protected final int getConfiguredPoolSize()
public final jsr166y.forkjoin.ForkJoinPool getForkJoinPool()
public final void resetDefaultSize()
public final void resize(int poolSize)
poolSize
- The new pool size
public final void shutdown()
Groovy Documentation