groovyx.gpars.scheduler
Class ForkJoinPoolEnhancer

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      jsr166y.ForkJoinPool
          groovyx.gpars.scheduler.ForkJoinPoolEnhancer

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class ForkJoinPoolEnhancer
extends jsr166y.ForkJoinPool

Enhanced the ForkJoinPool class with the resizing capability

Nested Class Summary

Nested classes/interfaces inherited from class jsr166y.ForkJoinPool

jsr166y.ForkJoinPool.ForkJoinWorkerThreadFactory, jsr166y.ForkJoinPool.ManagedBlocker

Field Summary

Fields inherited from class jsr166y.ForkJoinPool

defaultForkJoinWorkerThreadFactory

Constructor Summary

ForkJoinPoolEnhancer()

ForkJoinPoolEnhancer(int parallelism)

ForkJoinPoolEnhancer(int parallelism, jsr166y.ForkJoinPool.ForkJoinWorkerThreadFactory factory, java.lang.Thread.UncaughtExceptionHandler handler, boolean asyncMode)

Method Summary

(package private) void

addPoolActiveCount(int delta)

Methods inherited from class jsr166y.ForkJoinPool

awaitTermination, drainTasksTo, execute, execute, getActiveThreadCount, getAsyncMode, getFactory, getParallelism, getPoolSize, getQueuedSubmissionCount, getQueuedTaskCount, getRunningThreadCount, getStealCount, getUncaughtExceptionHandler, hasQueuedSubmissions, invoke, invokeAll, isQuiescent, isShutdown, isTerminated, isTerminating, managedBlock, newTaskFor, newTaskFor, pollSubmission, shutdown, shutdownNow, submit, submit, submit, submit, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer()

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer(int parallelism)

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer(int parallelism,
                            jsr166y.ForkJoinPool.ForkJoinWorkerThreadFactory factory,
                            java.lang.Thread.UncaughtExceptionHandler handler,
                            boolean asyncMode)

Method Detail

addPoolActiveCount

void addPoolActiveCount(int delta)