FJPool (org.codehaus.gpars)

groovyx.gpars.scheduler.FJPool

All Implemented Interfaces and Traits:

Pool
```
public class FJPool
extends java.lang.Object
```
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.
Authors:
Vaclav Pech Date: Feb 27, 2009

Field Summary

Fields
Modifiers	Name	Description
`private static long`	`DEFAULT_SHUTDOWN_TIMEOUT`
`private int`	`configuredPoolSize`
`protected java.util.concurrent.ForkJoinPool`	`pool`

Constructor Summary

Constructors
Constructor and description
`FJPool ()` Creates the pool with default number of threads.
`FJPool (int configuredPoolSize)` Creates the pool with specified number of threads.
`FJPool (java.util.concurrent.ForkJoinPool pool)` Creates the pool wrapping the provided ForkJoinPool

Methods Summary

Methods
Type	Name and description
`private static java.util.concurrent.ForkJoinPool`	`createPool(int poolSize)` Creates a fork/join pool of given size.
`void`	`execute(java.lang.Runnable task)` schedules a new task for processing with the pool
`protected int`	`getConfiguredPoolSize()`
`java.util.concurrent.ForkJoinPool`	`getForkJoinPool()` 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 DEFAULT_SHUTDOWN_TIMEOUT
  - private final int configuredPoolSize
  - protected final java.util.concurrent.ForkJoinPool pool
- Constructor Detail
  - public FJPool()
    
    Creates the pool with default number of threads.
  - public FJPool(int configuredPoolSize)
    
    Creates the pool with specified number of threads.
    Parameters:
    configuredPoolSize - The required size of the pool
  - public FJPool(java.util.concurrent.ForkJoinPool pool)
    
    Creates the pool wrapping the provided ForkJoinPool
    Parameters:
    pool - The ForkJoinPool instance to wrap
- Method Detail
  - private static java.util.concurrent.ForkJoinPool createPool(int poolSize)
    
    Creates a fork/join 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:
    poolSize - The required pool size
  - @java.lang.Override public void execute(java.lang.Runnable task)
    
    schedules a new task for processing with the pool
    Parameters:
    task - The task to schedule
  - protected final int getConfiguredPoolSize()
  - public final java.util.concurrent.ForkJoinPool getForkJoinPool()
    
    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 FJPool

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private static final long DEFAULT_SHUTDOWN_TIMEOUT

private final int configuredPoolSize

protected final java.util.concurrent.ForkJoinPool pool

Constructor Detail

public FJPool()

public FJPool(int configuredPoolSize)

public FJPool(java.util.concurrent.ForkJoinPool pool)

Method Detail

private static java.util.concurrent.ForkJoinPool createPool(int poolSize)

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

protected final int getConfiguredPoolSize()

public final java.util.concurrent.ForkJoinPool getForkJoinPool()

@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()