org.fusesource.hawtdispatch.internal.pool

Class SimplePool

java.lang.Object

org.fusesource.hawtdispatch.internal.pool.SimplePool

All Implemented Interfaces:

WorkerPool

public class SimplePool
extends java.lang.Object
implements WorkerPool

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEBUG
(package private) GlobalDispatchQueue	globalQueue
(package private) java.lang.ThreadGroup	group
(package private) java.lang.String	name
(package private) int	priority
(package private) boolean	shutdown
(package private) java.util.concurrent.ConcurrentLinkedQueue<Task>	tasks
(package private) SimpleThread[]	threads

Constructor Summary

Constructors

Constructor and Description
SimplePool(GlobalDispatchQueue globalQueue, int parallelism, DispatchPriority priority)

Method Summary

Modifier and Type	Method and Description
private SimpleThread	createWorker(int index)
protected void	debug(java.lang.String str, java.lang.Object... args)
protected void	debug(java.lang.Throwable thrown, java.lang.String str, java.lang.Object... args)
void	execute(Task runnable)
WorkerThread[]	getThreads()
void	park(SimpleThread thread)
private static int	priority(DispatchPriority priority)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

tasks

final java.util.concurrent.ConcurrentLinkedQueue<Task> tasks

globalQueue

final GlobalDispatchQueue globalQueue

name

final java.lang.String name

priority

final int priority

threads

final SimpleThread[] threads

shutdown

volatile boolean shutdown

group

final java.lang.ThreadGroup group

DEBUG

public static final boolean DEBUG

See Also:

Constant Field Values

Constructor Detail

SimplePool

public SimplePool(GlobalDispatchQueue globalQueue,
                  int parallelism,
                  DispatchPriority priority)

Method Detail

priority

private static int priority(DispatchPriority priority)

start

public void start()

Specified by:

start in interface WorkerPool

createWorker

private SimpleThread createWorker(int index)

getThreads

public WorkerThread[] getThreads()

Specified by:

getThreads in interface WorkerPool

shutdown

public void shutdown()

Specified by:

shutdown in interface WorkerPool

execute

public void execute(Task runnable)

Specified by:

execute in interface WorkerPool

park

public void park(SimpleThread thread)

debug

protected void debug(java.lang.String str,
                     java.lang.Object... args)

debug

protected void debug(java.lang.Throwable thrown,
                     java.lang.String str,
                     java.lang.Object... args)