DefaultPool (org.codehaus.gpars)

groovyx.gpars.scheduler.DefaultPool

All Implemented Interfaces and Traits:

Pool
```
public class DefaultPool
extends java.lang.Object
```
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

Fields
Modifiers	Name	Description
`private static long`	`SHUTDOWN_TIMEOUT`
`private java.util.concurrent.ThreadPoolExecutor`	`pool`
`private static java.util.concurrent.atomic.AtomicLong`	`threadCount`	Unique counter for Actors' threads

Constructor Summary

Constructors
Constructor and description
`DefaultPool ()` Creates the pool with default number of daemon threads.
`DefaultPool (boolean daemon)` Creates the pool with default number of threads.
`DefaultPool (boolean daemon, int poolSize)` Creates the pool with specified number of threads.
`DefaultPool (java.util.concurrent.ThreadPoolExecutor pool)` Creates the pool around the given executor service

Methods Summary

Methods
Type	Name and description
`private static java.util.concurrent.ThreadPoolExecutor`	`createPool(boolean daemon, int poolSize)` Creates a fixed-thread pool of given size.
`protected static java.lang.String`	`createThreadName()` Created a JVM-unique name for Actors' threads.
`void`	`execute(java.lang.Runnable task)` schedules a new task for processing with the pool
`java.util.concurrent.ExecutorService`	`getExecutorService()` Retrieves the internal executor service.
`int`	`getPoolSize()` Retrieves the current thread pool size
`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

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), 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
  - private static final long SHUTDOWN_TIMEOUT
  - private final java.util.concurrent.ThreadPoolExecutor pool
  - private static final java.util.concurrent.atomic.AtomicLong threadCount
    
    Unique counter for Actors' threads
- Constructor Detail
  - public DefaultPool()
    
    Creates the pool with default number of daemon threads.
  - public DefaultPool(boolean daemon)
    
    Creates the pool with default number of threads.
    Parameters:
    daemon - Sets the daemon flag of threads in the pool.
  - public DefaultPool(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
  - public DefaultPool(java.util.concurrent.ThreadPoolExecutor pool)
    
    Creates the pool around the given executor service
    Parameters:
    pool - The executor service to use
- Method Detail
  - private static java.util.concurrent.ThreadPoolExecutor createPool(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.
    Returns:
    The created thread pool
    The newly created thread pool
    Parameters:
    daemon - Sets the daemon flag of threads in the pool.
    poolSize - The required pool size
  - protected static java.lang.String createThreadName()
    
    Created a JVM-unique name for Actors' threads.
    Returns:
    The name prefix
  - @java.lang.Override public final void execute(java.lang.Runnable task)
    
    schedules a new task for processing with the pool
    Parameters:
    task - The task to schedule
  - public final java.util.concurrent.ExecutorService getExecutorService()
    
    Retrieves the internal executor service.
    Returns:
    The underlying thread pool
  - @java.lang.Override public int getPoolSize()
    
    Retrieves the current thread pool size
    Returns:
    The pool size
  - @java.lang.Override public final void resetDefaultSize()
    
    Sets the pool size to the default
  - @java.lang.Override public final void resize(int poolSize)
    
    Resizes the thread pool to the specified value
    Parameters:
    poolSize - The new pool size
  - @java.lang.Override public final void shutdown()
    
    Gently stops the pool

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class DefaultPool

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private static final long SHUTDOWN_TIMEOUT

private final java.util.concurrent.ThreadPoolExecutor pool

private static final java.util.concurrent.atomic.AtomicLong threadCount

Constructor Detail

public DefaultPool()

public DefaultPool(boolean daemon)

public DefaultPool(boolean daemon, int poolSize)

public DefaultPool(java.util.concurrent.ThreadPoolExecutor pool)

Method Detail

private static java.util.concurrent.ThreadPoolExecutor createPool(boolean daemon, int poolSize)

protected static java.lang.String createThreadName()

@java.lang.Override public final void execute(java.lang.Runnable task)

public final java.util.concurrent.ExecutorService getExecutorService()

@java.lang.Override public int getPoolSize()

@java.lang.Override public final void resetDefaultSize()

@java.lang.Override public final void resize(int poolSize)

@java.lang.Override public final void shutdown()