Package com.atlassian.bamboo.upgrade.tasks

Class MultiThreadedUpgradeRunner

java.lang.Object

com.atlassian.bamboo.upgrade.tasks.MultiThreadedUpgradeRunner

public class MultiThreadedUpgradeRunner
extends Object

A executor wrapper that allows for multi threaded upgrade tasks to be run easier

Constructor Summary

Constructors

Constructor	Description
MultiThreadedUpgradeRunner(int maxThreads)
MultiThreadedUpgradeRunner(int numberOfThreads, int queueCapacity)
MultiThreadedUpgradeRunner(@NotNull com.atlassian.config.db.HibernateConfig hibernateConfig)

Method Summary

Modifier and Type	Method	Description
void	checkException()
int	getActiveThreads()
void	submit(@NotNull Callable<Void> callable)
void	waitForTermination()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiThreadedUpgradeRunner

public MultiThreadedUpgradeRunner(int maxThreads)

MultiThreadedUpgradeRunner

public MultiThreadedUpgradeRunner(int numberOfThreads,
                                  int queueCapacity)

MultiThreadedUpgradeRunner

public MultiThreadedUpgradeRunner(@NotNull
                                  @NotNull com.atlassian.config.db.HibernateConfig hibernateConfig)

Method Detail

submit

public void submit(@NotNull
                   @NotNull Callable<Void> callable)
            throws InterruptedException,
                   UpgradeException

Throws:

InterruptedException

UpgradeException

waitForTermination

public void waitForTermination()
                        throws InterruptedException,
                               UpgradeException

Throws:

InterruptedException

UpgradeException

checkException

public void checkException()
                    throws UpgradeException

Throws:

UpgradeException

getActiveThreads

public int getActiveThreads()