com.atlassian.jira.task

Class ImportTaskManagerImpl

java.lang.Object

com.atlassian.jira.task.ImportTaskManagerImpl

All Implemented Interfaces:

ImportTaskManager

public class ImportTaskManagerImpl
extends Object
implements ImportTaskManager

An implementation of a ImportTaskManager. This manager uses an ExecutorService to run submitted tasks.

It should have *no* external dependencies and should *not* be injectable!

Since:

4.4

Constructor Summary

Constructors

Constructor and Description
ImportTaskManagerImpl()

Method Summary

Modifier and Type	Method and Description
void	clearCachedResourceBundleStrings() Clears a set of cached I18n strings used by import progress page (JRADEV-22513)
Map<String,String>	getCachedResourceBundleStrings() Returns a set of cached I18n strings used by import progress page (JRADEV-22513)
<V extends Serializable> TaskDescriptor<V>	getTask() Returns the TaskDescriptor of the current import task that's running
void	prepareCachedResourceBundleStrings(Locale locale) Prepares a set of cached I18n strings used by import progress page (JRADEV-22513)
void	shutdownNow() Attempts to aggressively stop the executing tasks and shuts down the underlying thread pool.
<V extends Serializable> TaskDescriptor<V>	submitTask(Callable<V> callable, String taskName) This submits a Callable task to the manager which can then be started at the managers discretion, but hopefully very soon.
<V extends Serializable> TaskDescriptor<V>	submitTask(Callable<V> callable, String taskName, SpanningOperation spanningOperation) This submits a Callable task to the manager which can then be started at the managers discretion, but hopefully very soon.

Methods inherited from class java.lang.Object

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

Constructor Detail

ImportTaskManagerImpl

public ImportTaskManagerImpl()

Method Detail

prepareCachedResourceBundleStrings

public void prepareCachedResourceBundleStrings(Locale locale)

Description copied from interface: ImportTaskManager

Prepares a set of cached I18n strings used by import progress page (JRADEV-22513)

Specified by:

prepareCachedResourceBundleStrings in interface ImportTaskManager

getCachedResourceBundleStrings

public Map<String,String> getCachedResourceBundleStrings()

Description copied from interface: ImportTaskManager

Returns a set of cached I18n strings used by import progress page (JRADEV-22513)

Specified by:

getCachedResourceBundleStrings in interface ImportTaskManager

Returns:

clearCachedResourceBundleStrings

public void clearCachedResourceBundleStrings()

Description copied from interface: ImportTaskManager

Clears a set of cached I18n strings used by import progress page (JRADEV-22513)

Specified by:

clearCachedResourceBundleStrings in interface ImportTaskManager

submitTask

public <V extends Serializable> TaskDescriptor<V> submitTask(@Nonnull
                                                             Callable<V> callable,
                                                             String taskName)
                                                      throws RejectedExecutionException

Description copied from interface: ImportTaskManager

This submits a Callable task to the manager which can then be started at the managers discretion, but hopefully very soon. The TaskDescriptor returned is a snapshot of the task's state when the method returns and will not change to reflect the task's future state changes.

Specified by:

submitTask in interface ImportTaskManager

Parameters:

callable - the long running task

taskName - An i18nized string describing this task

Returns:

a TaskDescriptor for the new long running task. The returned descriptor is a snapshot of the task state when the method returns and will not reflect any future changes.

Throws:

RejectedExecutionException - if the task manager is being shutdown and cannot accept new tasks.

AlreadyExecutingException - if another import task is already running in the task manager.

submitTask

public <V extends Serializable> TaskDescriptor<V> submitTask(@Nonnull
                                                             Callable<V> callable,
                                                             String taskName,
                                                             @Nullable
                                                             SpanningOperation spanningOperation)
                                                      throws RejectedExecutionException

Description copied from interface: ImportTaskManager

This submits a Callable task to the manager which can then be started at the managers discretion, but hopefully very soon. The TaskDescriptor returned is a snapshot of the task's state when the method returns and will not change to reflect the task's future state changes.

Specified by:

submitTask in interface ImportTaskManager

Parameters:

callable - the long running task

taskName - An i18nized string describing this task

spanningOperation - Operation that this task is part of

Returns:

a TaskDescriptor for the new long running task. The returned descriptor is a snapshot of the task state when the method returns and will not reflect any future changes.

Throws:

RejectedExecutionException - if the task manager is being shutdown and cannot accept new tasks.

AlreadyExecutingException - if another import task is already running in the task manager.

shutdownNow

public void shutdownNow()

Description copied from interface: ImportTaskManager

Attempts to aggressively stop the executing tasks and shuts down the underlying thread pool.

Specified by:

shutdownNow in interface ImportTaskManager

getTask

public <V extends Serializable> TaskDescriptor<V> getTask()

Description copied from interface: ImportTaskManager

Returns the TaskDescriptor of the current import task that's running

Specified by:

getTask in interface ImportTaskManager

Returns:

a TaskDescriptor or null if the manager has not such task. The descriptor returned is a snapshot of the task state when the method returns will not reflect any future changes. null will be returned when no matching task can be found.