com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T > Class Template Reference

Public Member Functions
	BatchProcessor (int batchSize, long secondsTimeout, Consumer< List< T >> itemsConsumer)
synchronized void	add (T item) throws InterruptedException
synchronized void	flushAndReset () throws InterruptedException

Private Member Functions
synchronized void	asyncProcessBatch () throws InterruptedException

Private Attributes
final BlockingQueue< T >	batchingQueue
final int	batchSize
final Consumer< List< T > >	itemsConsumer
ExecutorService	processingExecutorService = Executors.newSingleThreadExecutor()
final long	secondsTimeout

Detailed Description

Processes a batch when number of items reaches batchSize or flush. Processing blocks (and subsequently add and flush operations) until previous batch finishes.

Definition at line 39 of file BatchProcessor.java.

Constructor & Destructor Documentation

com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.BatchProcessor	(	int	batchSize,
		long	secondsTimeout,
		Consumer< List< T >>	itemsConsumer
	)

Definition at line 48 of file BatchProcessor.java.

Member Function Documentation

synchronized void com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.add

(

T

item

)

throws InterruptedException

Definition at line 55 of file BatchProcessor.java.

synchronized void com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.asyncProcessBatch ( ) throws InterruptedException

private

Definition at line 76 of file BatchProcessor.java.

Referenced by com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.add(), and com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.flushAndReset().

synchronized void com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.flushAndReset

(

)

throws InterruptedException

Definition at line 62 of file BatchProcessor.java.

Member Data Documentation

final BlockingQueue<T> com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.batchingQueue

private

Definition at line 43 of file BatchProcessor.java.

final int com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.batchSize

private

Definition at line 44 of file BatchProcessor.java.

Referenced by com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.add(), and com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.BatchProcessor().

final Consumer<List<T> > com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.itemsConsumer

private

Definition at line 45 of file BatchProcessor.java.

Referenced by com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.BatchProcessor().

ExecutorService com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.processingExecutorService = Executors.newSingleThreadExecutor()

private

Definition at line 41 of file BatchProcessor.java.

final long com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< T >.secondsTimeout

private

Definition at line 46 of file BatchProcessor.java.

Referenced by com.basistech.df.cybertriage.autopsy.malwarescan.BatchProcessor< FileRecord >.BatchProcessor().

---

The documentation for this class was generated from the following file:

• /home/carriersleuth/repos/autopsy/Core/src/com/basistech/df/cybertriage/autopsy/malwarescan/BatchProcessor.java