Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.scheduler
[Java] Class ResizeablePool

java.lang.Object
  groovyx.gpars.scheduler.DefaultPool
      groovyx.gpars.scheduler.ResizeablePool

public final class ResizeablePool
extends DefaultPool

Represents the actors' thread pool, which performs tasks on behalf of the actors. 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.

Authors:
Vaclav Pech Date: Feb 27, 2009

Field Summary
private static long KEEP_ALIVE_TIME

 
Fields inherited from class DefaultPool
SHUTDOWN_TIMEOUT, pool, threadCount
 
Constructor Summary
ResizeablePool(boolean daemon)

Creates the pool with default number of threads.
ResizeablePool(boolean daemon, int poolSize)

Creates the pool with specified number of threads.
 
Method Summary
private static java.util.concurrent.ThreadPoolExecutor createResizeablePool(boolean daemon, int poolSize)

Creates a fixed-thread pool of given size.

 
Methods inherited from class DefaultPool
createPool, createThreadName, execute, getExecutorService, getPoolSize, resetDefaultSize, resize, shutdown
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

KEEP_ALIVE_TIME

private static final long KEEP_ALIVE_TIME

 
Constructor Detail

ResizeablePool

public ResizeablePool(boolean daemon)
Creates the pool with default number of threads.
Parameters:
daemon - Sets the daemon flag of threads in the pool.

ResizeablePool

public ResizeablePool(boolean daemon, int poolSize)
Creates the pool with specified number of threads.
Parameters:
daemon - Sets the daemon flag of threads in the pool.
poolSize - The required size of the pool

 
Method Detail

createResizeablePool

private static java.util.concurrent.ThreadPoolExecutor createResizeablePool(boolean daemon, int poolSize)
Creates a fixed-thread pool of given size. Each thread will have the uncaught exception handler set to print the unhandled exception to standard error output.
Parameters:
daemon - Sets the daemon flag of threads in the pool.
poolSize - The required pool size
Returns:
The created thread pool
The newly created thread pool

 

Copyright © 2008–2010 Václav Pech. All Rights Reserved.