com.freedomoss.crowdcontrol.webharvest

Class RunExecutionThread

java.lang.Object

com.freedomoss.crowdcontrol.webharvest.RunExecutionThread

All Implemented Interfaces:

java.lang.Runnable

public class RunExecutionThread
extends java.lang.Object
implements java.lang.Runnable

Class that represent one thread in context of one run

Constructor Summary

Constructors

Constructor and Description

RunExecutionThread(java.lang.Long runId, javax.sql.DataSource dataSource, java.lang.Integer batchSize, com.freedomoss.crowdcontrol.webharvest.policy.ExecutionManager executionManager, com.freedomoss.requester.properties.ApplicationPropertiesBean propertiesBean, MachineWorkerPool workerPool, java.util.concurrent.ExecutorService executorService, java.lang.Long campaignSourceId, IWebharvestTaskExecutor webharvestTaskExecutor, com.freedomoss.requester.service.datastore.IDataStoreAccessor dataStoreAccessor, RetryTemplate failedLockRetryTemplate, long period, long delay, java.lang.String secureStorePassword, MachineServiceHolder serviceHolder)

Method Summary

Modifier and Type	Method and Description
void	finishRunThread()
void	forceStop() Force eagerly stop execution of all threads
java.util.Timer	getCheckingTimer()
java.lang.Long	getRunId()
java.util.List<SubmissionsPortionExecutionThread>	getThreadList()
void	handleError(java.lang.Throwable t)
boolean	isFinished() Tell if execution of this thread finished
void	purgeTimer()
void	run()
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RunExecutionThread

public RunExecutionThread(java.lang.Long runId,
                          javax.sql.DataSource dataSource,
                          java.lang.Integer batchSize,
                          com.freedomoss.crowdcontrol.webharvest.policy.ExecutionManager executionManager,
                          com.freedomoss.requester.properties.ApplicationPropertiesBean propertiesBean,
                          MachineWorkerPool workerPool,
                          java.util.concurrent.ExecutorService executorService,
                          java.lang.Long campaignSourceId,
                          IWebharvestTaskExecutor webharvestTaskExecutor,
                          com.freedomoss.requester.service.datastore.IDataStoreAccessor dataStoreAccessor,
                          RetryTemplate failedLockRetryTemplate,
                          long period,
                          long delay,
                          java.lang.String secureStorePassword,
                          MachineServiceHolder serviceHolder)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

purgeTimer

public void purgeTimer()

isFinished

public boolean isFinished()

Tell if execution of this thread finished

Returns:

boolean

forceStop

public void forceStop()

Force eagerly stop execution of all threads

getThreadList

public java.util.List<SubmissionsPortionExecutionThread> getThreadList()

getCheckingTimer

public java.util.Timer getCheckingTimer()

finishRunThread

public void finishRunThread()

getRunId

public java.lang.Long getRunId()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

handleError

public void handleError(java.lang.Throwable t)