Package com.atlassian.confluence.impl.backuprestore

Class ParallelTasksExecutor

java.lang.Object

com.atlassian.confluence.impl.backuprestore.ParallelTasksExecutor

All Implemented Interfaces:

AutoCloseable

public class ParallelTasksExecutor
extends Object
implements AutoCloseable

Allows to multiple tasks in parallel. Creates a queue for tasks.

Since:

7.20.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParallelTasksExecutor.TaskInfo

Constructor Summary

Constructors

Constructor	Description
ParallelTasksExecutor(int threadsNumber)

Method Summary

Modifier and Type	Method	Description
void	close()
void	interruptAllJobs()
Future<?>	runTaskAsync(Callable<Void> task, String info)
void	shutdown()
void	waitUntilAllJobsComplete()

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelTasksExecutor

public ParallelTasksExecutor(int threadsNumber)

Method Detail

runTaskAsync

public Future<?> runTaskAsync(Callable<Void> task,
                              String info)

shutdown

public void shutdown()
              throws InterruptedException

Throws:

InterruptedException

interruptAllJobs

public void interruptAllJobs()

waitUntilAllJobsComplete

public void waitUntilAllJobsComplete()
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException

close

public void close()
           throws InterruptedException

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException