com.amazonaws.services.cloudtrail.processinglibrary.factory

Class ThreadPoolFactory

java.lang.Object

com.amazonaws.services.cloudtrail.processinglibrary.factory.ThreadPoolFactory

public class ThreadPoolFactory
extends java.lang.Object

This class creates thread pool for ThreadPoolFactory.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ThreadPoolFactory.ProcessingLibraryThreadPoolExecutor When unexpected behavior happened, for example runtimeException.

Constructor Summary

Constructors

Constructor and Description
ThreadPoolFactory(int threadCount, ExceptionHandler exceptionHandler) A factory to create an instance of ExecutorService based on configuration

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.ExecutorService	createMainThreadPool() Create an instance of ExecutorService.
java.util.concurrent.ScheduledExecutorService	createScheduledThreadPool(int numOfParallelReaders) Create an instance of ScheduledExecutorService.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolFactory

public ThreadPoolFactory(int threadCount,
                         ExceptionHandler exceptionHandler)

A factory to create an instance of ExecutorService based on configuration

Parameters:

threadCount - number of threads

exceptionHandler - instance of ExceptionHandler

Method Detail

createScheduledThreadPool

public java.util.concurrent.ScheduledExecutorService createScheduledThreadPool(int numOfParallelReaders)

Create an instance of ScheduledExecutorService. We only need single thread to poll messages from the SQS queue.

Returns:

ScheduledExecutorService continuous poll messages from SQS queue.

createMainThreadPool

public java.util.concurrent.ExecutorService createMainThreadPool()

Create an instance of ExecutorService. ExecutorService is AWS CloudTrail Processing Library's main thread pool, used to process each CloudTrailSource. The thread pool queue, size are configurable through ProcessingConfiguration.

Returns:

ExecutorService that processes CloudTrailSource.