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 Scheduler

java.lang.Object
  groovyx.gpars.scheduler.Scheduler
All Implemented Interfaces:
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
private class Scheduler.WatchdogThread

private class Scheduler.WorkerThread

 
Field Summary
private static long POKE_INTERVAL

static java.lang.RuntimeException TERMINATE

private long lastTaskPoke

private java.util.concurrent.BlockingQueue queue

private long schedulerTime

private boolean terminating

private java.util.concurrent.atomic.AtomicInteger threadCount

 
Constructor Summary
Scheduler()

Scheduler(int coreSize)

 
Method Summary
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()

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

Field Detail

POKE_INTERVAL

private static final long POKE_INTERVAL

TERMINATE

static final java.lang.RuntimeException TERMINATE

lastTaskPoke

private long lastTaskPoke

queue

private final java.util.concurrent.BlockingQueue queue

schedulerTime

private long schedulerTime

terminating

private boolean terminating

threadCount

private final java.util.concurrent.atomic.AtomicInteger threadCount

 
Constructor Detail

Scheduler

public Scheduler()

Scheduler

public Scheduler(int coreSize)

 
Method Detail

execute

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

getPoolSize

@Override
public int getPoolSize()
Retrieves the current thread pool size
Returns:
The pool size

loop

public java.lang.Runnable loop(java.lang.Runnable operation)

resetDefaultSize

@Override
public void resetDefaultSize()

resize

@Override
public void resize(int poolSize)

shutdown

@Override
@SuppressWarnings({"ObjectAllocationInLoop"})
public void shutdown()

startNewThread

private void startNewThread()

 

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