org.jets3t.service.multithread

Class S3ServiceMulti.ThreadGroupManager

java.lang.Object

org.jets3t.service.multithread.S3ServiceMulti.ThreadGroupManager

Enclosing class:

S3ServiceMulti

private abstract class S3ServiceMulti.ThreadGroupManager
extends java.lang.Object

The thread group manager is responsible for starting, running and stopping the set of threads required to perform an S3 operation.

The manager starts all the threads, monitors their progress and stops threads when they are cancelled or an error occurs - all the while firing the appropriate ServiceEvent event notifications.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	S3ServiceMulti.ThreadGroupManager.ResultsTuple

Field Summary

Fields

Modifier and Type	Field and Description
private boolean[]	alreadyFired set of flags indicating which threads have already had In Progress events fired on their behalf.
private boolean	ignoreExceptions
private long	lastProgressEventFiredTime
private org.apache.commons.logging.Log	log
private int	maxThreadCount
private S3ServiceMulti.AbstractRunnable[]	runnables the set of runnable objects to execute.
private boolean[]	started set of flags indicating which runnable items have been started
private java.lang.Thread[]	threads Thread objects that are currently running, where the index corresponds to the runnables index.
private ThreadWatcher	threadWatcher

Constructor Summary

Constructors

Constructor and Description
ThreadGroupManager(S3ServiceMulti.AbstractRunnable[] runnables, ThreadWatcher threadWatcher, Jets3tProperties jets3tProperties, boolean isAdminTask)

Method Summary

Modifier and Type	Method and Description
abstract void	fireCancelEvent()
abstract void	fireCompletedEvent()
abstract void	fireErrorEvent(java.lang.Throwable t)
abstract void	fireIgnoredErrorsEvent(ThreadWatcher threadWatcher, java.lang.Throwable[] ignoredErrors)
abstract void	fireProgressEvent(ThreadWatcher threadWatcher, java.util.List completedResults)
abstract void	fireStartEvent(ThreadWatcher threadWatcher)
private void	forceInterruptAllRunnables() Invokes the S3ServiceMulti.AbstractRunnable.forceInterrupt() on all threads being managed.
private S3ServiceMulti.ThreadGroupManager.ResultsTuple	getNewlyCompletedResults() Determine which threads, if any, have finished since the last time an In Progress event was fired.
private int	getPendingThreadCount()
void	run() Runs and manages all the threads involved in an S3 multi-operation.
private void	startPendingThreads() Starts pending threads such that the total of running threads never exceeds the maximum count set in the jets3t property s3service.max-thread-count.

Methods inherited from class java.lang.Object

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

Field Detail

log

private final org.apache.commons.logging.Log log

maxThreadCount

private int maxThreadCount

runnables

private S3ServiceMulti.AbstractRunnable[] runnables

the set of runnable objects to execute.

threads

private java.lang.Thread[] threads

Thread objects that are currently running, where the index corresponds to the runnables index. Any AbstractThread runnable that is not started, or has completed, will have a null value in this array.

ignoreExceptions

private boolean ignoreExceptions

started

private boolean[] started

set of flags indicating which runnable items have been started

alreadyFired

private boolean[] alreadyFired

set of flags indicating which threads have already had In Progress events fired on their behalf. These threads have finished running.

threadWatcher

private ThreadWatcher threadWatcher

lastProgressEventFiredTime

private long lastProgressEventFiredTime

Constructor Detail

ThreadGroupManager

public ThreadGroupManager(S3ServiceMulti.AbstractRunnable[] runnables,
                          ThreadWatcher threadWatcher,
                          Jets3tProperties jets3tProperties,
                          boolean isAdminTask)

Method Detail

getNewlyCompletedResults

private S3ServiceMulti.ThreadGroupManager.ResultsTuple getNewlyCompletedResults()
                                                                         throws java.lang.Throwable

Determine which threads, if any, have finished since the last time an In Progress event was fired.

Returns:

a list of the threads that finished since the last In Progress event was fired. This list may be empty.

Throws:

java.lang.Throwable

startPendingThreads

private void startPendingThreads()
                          throws java.lang.Throwable

Starts pending threads such that the total of running threads never exceeds the maximum count set in the jets3t property s3service.max-thread-count.

Throws:

java.lang.Throwable

getPendingThreadCount

private int getPendingThreadCount()

Returns:

the number of threads that have not finished running (sum of those currently running, and those awaiting start)

forceInterruptAllRunnables

private void forceInterruptAllRunnables()

Invokes the S3ServiceMulti.AbstractRunnable.forceInterrupt() on all threads being managed.

run

public void run()

Runs and manages all the threads involved in an S3 multi-operation.

fireStartEvent

public abstract void fireStartEvent(ThreadWatcher threadWatcher)

fireProgressEvent

public abstract void fireProgressEvent(ThreadWatcher threadWatcher,
                                       java.util.List completedResults)

fireCompletedEvent

public abstract void fireCompletedEvent()

fireCancelEvent

public abstract void fireCancelEvent()

fireErrorEvent

public abstract void fireErrorEvent(java.lang.Throwable t)

fireIgnoredErrorsEvent

public abstract void fireIgnoredErrorsEvent(ThreadWatcher threadWatcher,
                                            java.lang.Throwable[] ignoredErrors)