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 ForkJoinPoolEnhancer

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

public class ForkJoinPoolEnhancer
extends jsr166y.ForkJoinPool

Enhanced the ForkJoinPool class with the resizing capability

Field Summary
 
Fields inherited from class jsr166y.ForkJoinPool
defaultForkJoinWorkerThreadFactory
 
Constructor Summary
ForkJoinPoolEnhancer()

ForkJoinPoolEnhancer(int parallelism)

ForkJoinPoolEnhancer(int parallelism, ForkJoinWorkerThreadFactory factory, java.lang.Object handler, boolean asyncMode)

 
Method Summary
void addPoolActiveCount(int delta)

 
Methods inherited from class jsr166y.ForkJoinPool
jsr166y.ForkJoinPool#invoke(jsr166y.ForkJoinTask), jsr166y.ForkJoinPool#shutdown(), jsr166y.ForkJoinPool#toString(), jsr166y.ForkJoinPool#getFactory(), jsr166y.ForkJoinPool#getUncaughtExceptionHandler(), jsr166y.ForkJoinPool#awaitTermination(long, java.util.concurrent.TimeUnit), jsr166y.ForkJoinPool#execute(jsr166y.ForkJoinTask), jsr166y.ForkJoinPool#execute(java.lang.Runnable), jsr166y.ForkJoinPool#shutdownNow(), jsr166y.ForkJoinPool#getPoolSize(), jsr166y.ForkJoinPool#isShutdown(), jsr166y.ForkJoinPool#isTerminated(), jsr166y.ForkJoinPool#isTerminating(), jsr166y.ForkJoinPool#invokeAll(java.util.Collection), jsr166y.ForkJoinPool#submit(java.lang.Runnable), jsr166y.ForkJoinPool#submit(java.lang.Runnable, java.lang.Object), jsr166y.ForkJoinPool#submit(jsr166y.ForkJoinTask), jsr166y.ForkJoinPool#submit(java.util.concurrent.Callable), jsr166y.ForkJoinPool#submit(java.lang.Runnable), jsr166y.ForkJoinPool#submit(java.lang.Runnable, java.lang.Object), jsr166y.ForkJoinPool#submit(java.util.concurrent.Callable), jsr166y.ForkJoinPool#getQueuedTaskCount(), jsr166y.ForkJoinPool#getParallelism(), jsr166y.ForkJoinPool#getAsyncMode(), jsr166y.ForkJoinPool#getRunningThreadCount(), jsr166y.ForkJoinPool#getActiveThreadCount(), jsr166y.ForkJoinPool#isQuiescent(), jsr166y.ForkJoinPool#getStealCount(), jsr166y.ForkJoinPool#getQueuedSubmissionCount(), jsr166y.ForkJoinPool#hasQueuedSubmissions(), jsr166y.ForkJoinPool#managedBlock(jsr166y.ForkJoinPool$ManagedBlocker), jsr166y.ForkJoinPool#invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit), jsr166y.ForkJoinPool#invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit), jsr166y.ForkJoinPool#invokeAny(java.util.Collection), jsr166y.ForkJoinPool#wait(long), jsr166y.ForkJoinPool#wait(), jsr166y.ForkJoinPool#wait(long, int), jsr166y.ForkJoinPool#equals(java.lang.Object), jsr166y.ForkJoinPool#hashCode(), jsr166y.ForkJoinPool#getClass(), jsr166y.ForkJoinPool#notify(), jsr166y.ForkJoinPool#notifyAll()
 
Methods inherited from class java.util.concurrent.AbstractExecutorService
java.util.concurrent.AbstractExecutorService#invokeAll(java.util.Collection), java.util.concurrent.AbstractExecutorService#invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit), java.util.concurrent.AbstractExecutorService#invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit), java.util.concurrent.AbstractExecutorService#invokeAny(java.util.Collection), java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable), java.util.concurrent.AbstractExecutorService#submit(java.lang.Runnable, java.lang.Object), java.util.concurrent.AbstractExecutorService#submit(java.util.concurrent.Callable), java.util.concurrent.AbstractExecutorService#wait(long), java.util.concurrent.AbstractExecutorService#wait(), java.util.concurrent.AbstractExecutorService#wait(long, int), java.util.concurrent.AbstractExecutorService#equals(java.lang.Object), java.util.concurrent.AbstractExecutorService#toString(), java.util.concurrent.AbstractExecutorService#hashCode(), java.util.concurrent.AbstractExecutorService#getClass(), java.util.concurrent.AbstractExecutorService#notify(), java.util.concurrent.AbstractExecutorService#notifyAll(), java.util.concurrent.AbstractExecutorService#shutdown(), java.util.concurrent.AbstractExecutorService#awaitTermination(long, java.util.concurrent.TimeUnit), java.util.concurrent.AbstractExecutorService#shutdownNow(), java.util.concurrent.AbstractExecutorService#isShutdown(), java.util.concurrent.AbstractExecutorService#isTerminated(), java.util.concurrent.AbstractExecutorService#execute(java.lang.Runnable)
 
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()
 

Constructor Detail

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer()

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer(int parallelism)

ForkJoinPoolEnhancer

public ForkJoinPoolEnhancer(int parallelism, ForkJoinWorkerThreadFactory factory, java.lang.Object handler, boolean asyncMode)

 
Method Detail

addPoolActiveCount

void addPoolActiveCount(int delta)

 

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