com.atlassian.bamboo.upgrade.tasks
Class MultiThreadedUpgradeRunner

java.lang.Object
  com.atlassian.bamboo.upgrade.tasks.MultiThreadedUpgradeRunner

public class MultiThreadedUpgradeRunner
extends java.lang.Object

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

Constructor Summary

MultiThreadedUpgradeRunner(int maxThreads)

MultiThreadedUpgradeRunner(int numberOfThreads, int queueCapacity)

Method Summary

void	checkException()
int	getActiveThreads()
void	submit(java.util.concurrent.Callable<java.lang.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)

Method Detail

submit

public void submit(@NotNull
                   java.util.concurrent.Callable<java.lang.Void> callable)
            throws java.lang.InterruptedException,
                   com.atlassian.upgrade.UpgradeException

Throws:

java.lang.InterruptedException

com.atlassian.upgrade.UpgradeException

waitForTermination

public void waitForTermination()
                        throws java.lang.InterruptedException,
                               com.atlassian.upgrade.UpgradeException

Throws:

java.lang.InterruptedException

com.atlassian.upgrade.UpgradeException

checkException

public void checkException()
                    throws com.atlassian.upgrade.UpgradeException

Throws:

com.atlassian.upgrade.UpgradeException

getActiveThreads

public int getActiveThreads()