it.cnr.isti.hpc.parallel

Class ThreadPool

java.lang.Object

it.cnr.isti.hpc.parallel.ThreadPool

public class ThreadPool
extends Object

ThreadPool allows to run a simple job in parallel using a pool of threads. The jobs comes as a class implementing the interface FunctionToExec and the input is a unique file where each line is an input to be processed. Each thread pulls a line and process it, then writes the output on a individual or shared file.

Author:

Diego Ceccarelli Created on Nov 19, 2012

See Also:

FunctionToExec

Constructor Summary

Constructors

Constructor and Description
ThreadPool(int nThreads, String inputFile, FunctionToExec function) Creates the thread pull.

Method Summary

Methods

Modifier and Type	Method and Description
ThreadPool	flush() Performs the flush everytime a thread writes something (for debugging)
void	run() Starts the threads.
ThreadPool	setOutputFile(String file) Sets the output file name.
ThreadPool	setOutputFolder(String folder) Sets the output folder.
ThreadPool	setThreadSleepTime(long millis) Sets thread sleep time
ThreadPool	useOnlyOneOutputFile() Uses only one output file.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPool

public ThreadPool(int nThreads,
          String inputFile,
          FunctionToExec function)

Creates the thread pull.

Parameters:

nThreads - number of thread to use.

inputFile - the input file, each line is an input for a thread.

function - the action that each thread has to perform.

Method Detail

flush

public ThreadPool flush()

Performs the flush everytime a thread writes something (for debugging)

Returns:

this threadpool

useOnlyOneOutputFile

public ThreadPool useOnlyOneOutputFile()

Uses only one output file.

Returns:

this threadpool

setThreadSleepTime

public ThreadPool setThreadSleepTime(long millis)

Sets thread sleep time

Returns:

this threadpool

setOutputFolder

public ThreadPool setOutputFolder(String folder)

Sets the output folder.

Parameters:

folder - the output folder

Returns:

this threadpool

setOutputFile

public ThreadPool setOutputFile(String file)

Sets the output file name.

Parameters:

file - the output file

Returns:

this thread pool

run

public void run()

Starts the threads.