Scheduler (org.codehaus.gpars)

| Detail:
Field
Constructor
Method

groovyx.gpars.scheduler.Scheduler

All Implemented Interfaces and Traits:

Pool
```
public final class Scheduler
extends java.lang.Object
```
Prototype of self-regulated thread pooled scheduler
Self regulation happened according to following rules:
- worker thread, which had nothing to do 10 seconds dies
- if no tasks were taken for processing during last 0.5sec new worker starts

Nested Class Summary

Nested classes
Modifiers	Name	Description
`private class`	`Scheduler.WatchdogThread`
`private class`	`Scheduler.WorkerThread`

Field Summary

Fields
Modifiers	Name	Description
`private static long`	`POKE_INTERVAL`
`static java.lang.RuntimeException`	`TERMINATE`
`private long`	`lastTaskPoke`
`private java.util.concurrent.BlockingQueue<java.lang.Runnable>`	`queue`
`private long`	`schedulerTime`
`private boolean`	`terminating`
`private java.util.concurrent.atomic.AtomicInteger`	`threadCount`

Constructor Summary

Constructors
Constructor and description
`Scheduler ()`
`Scheduler (int coreSize)`

Methods Summary

Methods
Type	Name and description
`void`	`execute(java.lang.Runnable task)`
`int`	`getPoolSize()` Retrieves the current thread pool size
`java.lang.Runnable`	`loop(java.lang.Runnable operation)`
`void`	`resetDefaultSize()`
`void`	`resize(int poolSize)`
`void`	`shutdown()`
`private void`	`startNewThread()`

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 POKE_INTERVAL
  - static final java.lang.RuntimeException TERMINATE
  - private long lastTaskPoke
  - private final java.util.concurrent.BlockingQueue<java.lang.Runnable> queue
  - private long schedulerTime
  - private boolean terminating
  - private final java.util.concurrent.atomic.AtomicInteger threadCount
- Constructor Detail
  - public Scheduler()
  - public Scheduler(int coreSize)
- Method Detail
  - @java.lang.Override public void execute(java.lang.Runnable task)
  - @java.lang.Override public int getPoolSize()
    
    Retrieves the current thread pool size
    Returns:
    The pool size
  - public java.lang.Runnable loop(java.lang.Runnable operation)
  - @java.lang.Override public void resetDefaultSize()
  - @java.lang.Override public void resize(int poolSize)
  - @java.lang.Override @java.lang.SuppressWarnings({"ObjectAllocationInLoop"}) public void shutdown()
  - private void startNewThread()

| Detail:
Field
Constructor
Method

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