hu.juranyi.zsolt.pubsearch.crawl

Class ThreadScheduler

java.lang.Object

java.lang.Thread

hu.juranyi.zsolt.pubsearch.crawl.ThreadScheduler

All Implemented Interfaces:

java.lang.Runnable

public class ThreadScheduler
extends java.lang.Thread

ThreadScheduler can help you limit the count of actually running threads. Just create an instance, add your threads with add() and call start(). ThreadScheduler will start your threads in order, and guarantees that the count of running threads at the same time will never be above the limit. ThreadScheduler thread will stop when all of your threads end, so you can wait for it with a simple while (threadScheduler.isAlive()); cycle or you can use startAndWait() method which does the same. When ThreadScheduler gets an interrupt, sends it to all running threads, waits for them to die, then clears the list and stops.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ThreadScheduler() Creates a ThreadScheduler with default name and thread count limit.
ThreadScheduler(int limit) Creates a ThreadScheduler with default name and given thread count limit.
ThreadScheduler(java.lang.String name) Creates a ThreadScheduler with given name and default thread count limit.
ThreadScheduler(java.lang.String name, int limit) Creates a ThreadScheduler with given name and thread count limit

Method Summary

Methods

Modifier and Type	Method and Description
void	add(java.lang.Thread t)
int	getAllThreadCount()
int	getRunningThreadCount()
int	getWaitingThreadCount()
void	interrupt() Interrupts all threads.
void	run()
void	startAndWait() Starts the scheduler, then waits for it to stop working.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadScheduler

public ThreadScheduler()

Creates a ThreadScheduler with default name and thread count limit.

ThreadScheduler

public ThreadScheduler(int limit)

Creates a ThreadScheduler with default name and given thread count limit.

Parameters:

limit - Maximum number of threads can run at the same time.

ThreadScheduler

public ThreadScheduler(java.lang.String name)

Creates a ThreadScheduler with given name and default thread count limit.

Parameters:

name - Name of the ThreadScheduler thread.

ThreadScheduler

public ThreadScheduler(java.lang.String name,
               int limit)

Creates a ThreadScheduler with given name and thread count limit

Parameters:

name - Name of the ThreadScheduler thread.

limit - Maximum number of threads can run at the same time.

Method Detail

add

public void add(java.lang.Thread t)

getAllThreadCount

public int getAllThreadCount()

getRunningThreadCount

public int getRunningThreadCount()

getWaitingThreadCount

public int getWaitingThreadCount()

interrupt

public void interrupt()

Interrupts all threads.

Overrides:

interrupt in class java.lang.Thread

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

startAndWait

public void startAndWait()

Starts the scheduler, then waits for it to stop working. If scheduler gets an interrupt, the running threads will be waited.