com.freedomoss.crowdcontrol.webharvest

Class SubmissionsPortionExecutionThread

java.lang.Object

com.freedomoss.crowdcontrol.webharvest.SubmissionsPortionExecutionThread

All Implemented Interfaces:

java.lang.Runnable

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

Thread that process number portion of submissions

Constructor Summary

Constructors

Constructor and Description

SubmissionsPortionExecutionThread(int batchNumber, java.util.List<SubmissionDto> submissions, RunDto run, CampaignDto campaign, javax.sql.DataSource dataSource, com.freedomoss.crowdcontrol.webharvest.policy.ExecutionManager executionManager, MachineWorkerPool workerPool, java.util.concurrent.atomic.AtomicBoolean automatedRunInfoUpdated, IWebharvestTaskExecutor webharvestTaskExecutor, java.util.Map<java.lang.String,java.lang.String> includedConfigs, DatabaseProperties dataStoreProperties, RetryTemplate failedLockRetryTemplate, int processingCount, com.freedomoss.requester.properties.ApplicationPropertiesBean applicationProperties, boolean wait, java.lang.String secureStorePassword, MachineServiceHolder serviceHolder) Public constructor

Method Summary

Modifier and Type	Method and Description
void	forceStop() Force stop execution of this thread
int	getBatchNumber()
java.lang.Thread	getExecutingThread()
RunDto	getRun()
java.util.List<java.lang.Long>	getSubmissionIds()
boolean	isFinished() Return true if execution of thread was finished
boolean	isStarted()
void	run()
void	setStatus(SubmissionsPortionExecutionThreadStatus status)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SubmissionsPortionExecutionThread

public SubmissionsPortionExecutionThread(int batchNumber,
                                         java.util.List<SubmissionDto> submissions,
                                         RunDto run,
                                         CampaignDto campaign,
                                         javax.sql.DataSource dataSource,
                                         com.freedomoss.crowdcontrol.webharvest.policy.ExecutionManager executionManager,
                                         MachineWorkerPool workerPool,
                                         java.util.concurrent.atomic.AtomicBoolean automatedRunInfoUpdated,
                                         IWebharvestTaskExecutor webharvestTaskExecutor,
                                         java.util.Map<java.lang.String,java.lang.String> includedConfigs,
                                         DatabaseProperties dataStoreProperties,
                                         RetryTemplate failedLockRetryTemplate,
                                         int processingCount,
                                         com.freedomoss.requester.properties.ApplicationPropertiesBean applicationProperties,
                                         boolean wait,
                                         java.lang.String secureStorePassword,
                                         MachineServiceHolder serviceHolder)

Public constructor

Parameters:

batchNumber - number of the portion

workerPool - machine workers pool

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

setStatus

public void setStatus(SubmissionsPortionExecutionThreadStatus status)

getBatchNumber

public int getBatchNumber()

getRun

public RunDto getRun()

isFinished

public boolean isFinished()

Return true if execution of thread was finished

Returns:

boolean

isStarted

public boolean isStarted()

forceStop

public void forceStop()

Force stop execution of this thread

getSubmissionIds

public java.util.List<java.lang.Long> getSubmissionIds()

getExecutingThread

public java.lang.Thread getExecutingThread()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object