Package com.attivio.connector

Class ConcurrentScannerTaskExecuter

java.lang.Object

com.attivio.connector.ConcurrentScannerTaskExecuter

All Implemented Interfaces:

TaskStateAware, java.io.Closeable, java.lang.AutoCloseable

public class ConcurrentScannerTaskExecuter
extends java.lang.Object
implements java.io.Closeable, TaskStateAware

Executes multiple document fetcher tasks

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConcurrentScannerTaskExecuter.ConcurrentExecutionMetrics

Constructor Summary

Constructors

Constructor	Description
ConcurrentScannerTaskExecuter(int numThreads)

Method Summary

Modifier and Type	Method	Description
void	cancelPendigTasks()
void	close()
java.util.Map<ConcurrentScannerDocFetcherTask.TaskState,java.lang.Long>	countByState()
void	failed(java.lang.String uuid)	The task failed.
java.util.stream.Stream<java.lang.String>	getTaskUuids(ConcurrentScannerDocFetcherTask.TaskState state)
int	numQueued()
boolean	queue(ConcurrentScannerDocFetcherTask task)
void	started(java.lang.String uuid)
void	succeeded(java.lang.String uuid)	The task completed successfully.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentScannerTaskExecuter

public ConcurrentScannerTaskExecuter(int numThreads)

Method Detail

queue

public boolean queue(ConcurrentScannerDocFetcherTask task)

numQueued

public int numQueued()

started

public void started(java.lang.String uuid)

Specified by:

started in interface TaskStateAware

succeeded

public void succeeded(java.lang.String uuid)

Description copied from interface: TaskStateAware

The task completed successfully.

Specified by:

succeeded in interface TaskStateAware

failed

public void failed(java.lang.String uuid)

Description copied from interface: TaskStateAware

The task failed.

Specified by:

failed in interface TaskStateAware

getTaskUuids

public java.util.stream.Stream<java.lang.String> getTaskUuids(ConcurrentScannerDocFetcherTask.TaskState state)

countByState

public java.util.Map<ConcurrentScannerDocFetcherTask.TaskState,java.lang.Long> countByState()

cancelPendigTasks

public void cancelPendigTasks()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable