org.linqs.psl.util

Class Parallel.Worker<T>

java.lang.Object

org.linqs.psl.util.Parallel.Worker<T>

All Implemented Interfaces:

Cloneable, Runnable

Enclosing class:

Parallel

public abstract static class Parallel.Worker<T>
extends Object
implements Runnable, Cloneable

Extend this class for any work. Default implmentation are provided for all non-abstract, non-final methods.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	id

Constructor Summary

Constructors

Constructor and Description
Worker()

Method Summary

Modifier and Type	Method and Description
void	clearException()
void	close() Cleanup anything.
Parallel.Worker<T>	copy() Make a deep copy of this worker.
Exception	getException()
long	getWaitTime()
long	getWorkTime()
void	init(int id) Called before any work is given.
void	run()
void	setWork(int index, T item)
abstract void	work(int index, T item) Do the actual work.

Methods inherited from class java.lang.Object

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

Field Detail

id

protected int id

Constructor Detail

Worker

public Worker()

Method Detail

close

public void close()

Cleanup anything. Called after all work has been complete and it is time to clean up.

copy

public Parallel.Worker<T> copy()

Make a deep copy of this worker. Called when the manager is getting the correct number of workers ready.

init

public void init(int id)

Called before any work is given. The id will be unique to this worker for this batch of work.

clearException

public void clearException()

getException

public Exception getException()

getWaitTime

public long getWaitTime()

getWorkTime

public long getWorkTime()

run

public final void run()

Specified by:

run in interface Runnable

setWork

public final void setWork(int index,
                          T item)

work

public abstract void work(int index,
                          T item)

Do the actual work. The index is the item's index in the collection.